nsq

type Transport struct {

	// NewProducer is a func that creates an nsq.Producer.
	NewProducer func() (*nsq.Producer, error)

	// NewConsumer is a func that creates an nsq.Consumer.
	NewConsumer func(name string) (*nsq.Consumer, error)

	// ConnectConsumer is a func that connects the nsq.Consumer
	// to NSQ.
	ConnectConsumer func(consumer *nsq.Consumer) error
	// contains filtered or unexported fields
}