ConsumerChain returns a single interceptor from multiple interceptors.

NewMockConsumerItf creates a new mock instance.

NewMockProducerItf creates a new mock instance.

NewProducer creates a client to publish message to nsq.

MockConsumerItf is a mock of ConsumerItf interface.

MockConsumerItfMockRecorder is the mock recorder for MockConsumerItf.

MockProducerItf is a mock of ProducerItf interface.

MockProducerItfMockRecorder is the mock recorder for MockProducerItf.

ConsumerItf is consumer interface to consume nsq message.

ProducerItf is producer interface to publish nsq message.

FuncConsumer is a type to allow callers to wrap a raw func.