nsq

Documentation

Index

• type MessageHandler
  • func NewMessageHandler(nsqServer string, channel string) (mh *MessageHandler, err error)
  • func (m *MessageHandler) Registry(topic string, ch chan []byte)
• type Producer
  • func NewProducer(addr string) (producer *Producer, err error)
  • func (m *Producer) Publish(topic string, data []byte) (err error)

Types

type MessageHandler

type MessageHandler struct {
	Channel string
	// contains filtered or unexported fields
}

MessageHandler MessageHandler

func NewMessageHandler

func NewMessageHandler(nsqServer string, channel string) (mh *MessageHandler, err error)

NewMessageHandler return new MessageHandler

func (*MessageHandler) Registry

func (m *MessageHandler) Registry(topic string, ch chan []byte)

Registry registry nsq topic

type Producer

type Producer struct {
	P *gnsq.Producer
}

Producer Producer

func NewProducer

func NewProducer(addr string) (producer *Producer, err error)

NewProducer init

return producer

func (*Producer) Publish

func (m *Producer) Publish(topic string, data []byte) (err error)

Publish publish topic

return error