NewAckManager returns a AckManager without monitoring the itemIDs continousness.

NewContinuousAckManager returns a ContinuousAckManager it will emit error logs for itemIDs being incontinuous This is useful for some message queue system that guarantees continuousness that we want to monitor it's behaving correctly.

NewMetricProducer creates a new instance of producer that emits metrics.

NewMockAckManager creates a new mock instance.

NewMockClient creates a new mock instance.

NewMockCloseableProducer creates a new mock instance.

NewMockConsumer creates a new mock instance.

NewMockMessage creates a new mock instance.

NewMockProducer creates a new mock instance.

NewNoopProducer returns a no-op message producer.

ErrMessageSizeLimit indicate that message is rejected by server due to size limitation.

MockAckManager is a mock of AckManager interface.

MockAckManagerMockRecorder is the mock recorder for MockAckManager.

MockClient is a mock of Client interface.

MockClientMockRecorder is the mock recorder for MockClient.

MockCloseableProducer is a mock of CloseableProducer interface.

MockCloseableProducerMockRecorder is the mock recorder for MockCloseableProducer.

MockConsumer is a mock of Consumer interface.

MockConsumerMockRecorder is the mock recorder for MockConsumer.

MockMessage is a mock of Message interface.

MockMessageMockRecorder is the mock recorder for MockMessage.

MockProducer is a mock of Producer interface.

MockProducerMockRecorder is the mock recorder for MockProducer.