consumer

Documentation

Index

• Constants
• type Consumer
  • func NewConsumer(con Type) Consumer
  • func NewPullConsumer() Consumer
  • func NewPushConsumer() Consumer
• type Expression
• type Message
• type Status
• type Topic
• type Type

Constants

const (
	ConOk   = Status(0)
	ConFail = Status(1)
)

const (
	ConTypePush = Type(0)
	ConTypePull = Type(1)
)

Types

type Consumer

type Consumer interface {
	Start(cfg server.MqConfig) error

	Stop()

	/* 建议外面使用 go goroutine */
	Subscribe(topic Topic, exp Expression, call func(msg *Message) Status) error
}

func NewConsumer

func NewConsumer(con Type) Consumer

func NewPullConsumer

func NewPullConsumer() Consumer

func NewPushConsumer

func NewPushConsumer() Consumer

type Expression

type Expression struct {
	Type string
	Exp  string
}

type Message

type Message struct {
	MsgId    string
	QueueId  int
	Topic    string
	Tags     string
	Keys     string
	Body     string
	Property map[string]string
}

type Status

type Status int

type Topic

type Topic struct {
	Topic      string
	BrokerName string
	QueueId    int
}

type Type

type Type int