mq

Documentation

Index

• type ConsumerMessage
• type IConsumer
• type IProducer
• type ProducerMessage
• type TestMsg

Types

type ConsumerMessage

type ConsumerMessage struct {
	Value interface{}
}

type IConsumer

type IConsumer interface {
	io.Closer
	BytesMessages() <-chan []byte     // 返回消息内容管道
	BindJSONChan(channel interface{}) // 绑定JSON管道，输出已经过反序列化的对象
}

type IProducer

type IProducer interface {
	io.Closer
	SendJSON(topic string, value interface{}) (interface{}, error) // 发布JSON消息
	SendJSONs(messages []*ProducerMessage) error                   // 批量发布JSON消息
}

type ProducerMessage

type ProducerMessage struct {
	Topic string
	Value interface{}
}

type TestMsg

type TestMsg struct {
	Message string        `json:"message"`
	Time    date.Datetime `json:"time"`
}