Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NSQConsumer ¶
type NSQConsumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func NewConsumer(c *nsq.Consumer, addr string) (nsqc *NSQConsumer, err error)
func (*NSQConsumer) Consume ¶
func (nsqc *NSQConsumer) Consume() (rc <-chan []byte, err error)
func (*NSQConsumer) HandleMessage ¶
func (nsqc *NSQConsumer) HandleMessage(msg *nsq.Message) error
type NSQProducer ¶
type NSQProducer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer(p *nsq.Producer, topic string) (nsqp *NSQProducer, err error)
func (*NSQProducer) Close ¶
func (nsqd *NSQProducer) Close() error
func (*NSQProducer) Publish ¶
func (nsqp *NSQProducer) Publish(msg []byte) error
func (*NSQProducer) PublishMulti ¶
func (nsqp *NSQProducer) PublishMulti(msgs [][]byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.