consumer

Documentation

Index

• Constants
• type Consumer
  • func NewConsumer(con Type, cfg server.MqConfig) Consumer
  • func NewPullConsumer(cfg server.MqConfig) Consumer
  • func NewPushConsumer(cfg server.MqConfig) 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() error

	Stop()

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

func NewConsumer

func NewConsumer(con Type, cfg server.MqConfig) Consumer

func NewPullConsumer

func NewPullConsumer(cfg server.MqConfig) Consumer

func NewPushConsumer

func NewPushConsumer(cfg server.MqConfig) 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