Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Producer *nsq.Producer
)
Functions ¶
func AddConsumer ¶
func AddConsumer(c *nsq.Consumer)
func InitProducer ¶
func InitProducer(config ProducerConfig)
func NewConsumer ¶
func NewConsumer(config ConsumerConfig) *nsq.Consumer
func StopConsumers ¶
func StopConsumers()
func StopProducer ¶
func StopProducer()
Types ¶
type ConsumerConfig ¶
type ConsumerConfig struct { Topic string Channel string Address string AuthSecret string Handler *MessageHandler }
type MessageHandler ¶
func (*MessageHandler) HandleMessage ¶
func (h *MessageHandler) HandleMessage(m *nsq.Message) error
type ProducerConfig ¶
Click to show internal directories.
Click to hide internal directories.