nats

Documentation

Index

• type Consumer
  • func NewConsumer(queue string, topic string) *Consumer
  • func (c *Consumer) BindJSONChan(channel interface{})
  • func (c *Consumer) BytesMessages() <-chan []byte
  • func (c *Consumer) Close() error
  • func (c *Consumer) GetLogger() *logger.Logger
  • func (c *Consumer) SetLogger(log *logger.Logger)
• type Producer
  • func NewProducer() *Producer
  • func (p *Producer) Close() error
  • func (p *Producer) GetLogger() *logger.Logger
  • func (p *Producer) SendJSON(topic string, value interface{}) (result interface{}, err error)
  • func (p *Producer) SendJSONs(messages []*mq.ProducerMessage) (err error)
  • func (p *Producer) SetLogger(log *logger.Logger)

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

消费者对象

func NewConsumer

func NewConsumer(queue string, topic string) *Consumer

新建消费者

func (*Consumer) BindJSONChan

func (c *Consumer) BindJSONChan(channel interface{})

将消息输出绑定到指定管道上，此方法内会进行反序列化，输出的消息类型可以是指定对象类型

func (*Consumer) BytesMessages

func (c *Consumer) BytesMessages() <-chan []byte

消息读取管道，管道消息类型是byte切片

func (*Consumer) Close

func (c *Consumer) Close() error

关闭

func (*Consumer) GetLogger

func (c *Consumer) GetLogger() *logger.Logger

获取当前日志记录器

func (*Consumer) SetLogger

func (c *Consumer) SetLogger(log *logger.Logger)

指定日志记录器

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

生产者对象

func NewProducer

func NewProducer() *Producer

新建生产者

func (*Producer) Close

func (p *Producer) Close() error

关闭

func (*Producer) GetLogger

func (p *Producer) GetLogger() *logger.Logger

获取当前日志记录器

func (*Producer) SendJSON

func (p *Producer) SendJSON(topic string, value interface{}) (result interface{}, err error)

发送单条消息

func (*Producer) SendJSONs

func (p *Producer) SendJSONs(messages []*mq.ProducerMessage) (err error)

批量发送消息

func (*Producer) SetLogger

func (p *Producer) SetLogger(log *logger.Logger)

指定日志记录器