consumer

Documentation

Index

• type NSQConsumer
  • func NewNSQConsumer(topic, channel, addr string) *NSQConsumer
  • func (n *NSQConsumer) Consumer(h nsq.Handler)

Types

type NSQConsumer

type NSQConsumer struct {
	Topic   string `json:"topic"`
	Channel string `json:"channel"`
	Addr    string `json:"addr"`
}

func NewNSQConsumer

func NewNSQConsumer(topic, channel, addr string) *NSQConsumer

func (*NSQConsumer) Consumer

func (n *NSQConsumer) Consumer(h nsq.Handler)