Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.