README
Documentation
¶
Index ¶
- func AddConcurrentHandlers(topic, channel string, handler nsq.Handler, concurrency int) error
- func AddConsumer(topic, channel string, handler nsq.Handler) error
- func AddHandler(topic, channel string, handler nsq.Handler) error
- func AddProducer(addr string, config *nsq.Config) (*nsq.Producer, error)
- func GetConsumer(topic, channel string) (consumers []*nsq.Consumer)
- func NewConfig() *nsq.Config
- func NewConsumerMgr(config *nsq.Config, lookupdAddrs []string)
- func Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddConcurrentHandlers ¶
func AddConsumer ¶
func AddHandler ¶
func AddProducer ¶
func GetConsumer ¶
func GetConsumer(topic, channel string) (consumers []*nsq.Consumer)
func NewConsumerMgr ¶
func NewConsumerMgr(config *nsq.Config, lookupdAddrs []string)
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.