Versions in this module Expand all Collapse all v1 v1.0.1 Aug 11, 2020 v1.0.0 Aug 7, 2019 Changes in this version + type ConsumerT struct + func (c *ConsumerT) NsqConsumers() + func (c ConsumerT) HandleMessage(msg *nsq.Message) error + type ProducerT struct + func (p *ProducerT) InitProducer() error + func (p *ProducerT) Publish(topic, message string) error + func (p *ProducerT) Stop()
Go to main page