nsq_demo

Documentation

Index

• type ConsumerT
  • func (c ConsumerT) HandleMessage(msg *nsq.Message) error
  • func (c *ConsumerT) NsqConsumers()
• type ProducerT
  • func (p *ProducerT) InitProducer() error
  • func (p *ProducerT) Publish(topic, message string) error
  • func (p *ProducerT) Stop()

Types

type ConsumerT

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

func (ConsumerT) HandleMessage

func (c ConsumerT) HandleMessage(msg *nsq.Message) error

func (*ConsumerT) NsqConsumers

func (c *ConsumerT) NsqConsumers()

type ProducerT

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

func (*ProducerT) InitProducer

func (p *ProducerT) InitProducer() error

func (*ProducerT) Publish

func (p *ProducerT) Publish(topic, message string) error

func (*ProducerT) Stop

func (p *ProducerT) Stop()