NewFake builds a new Queuer using a single buffered channel and returns it.

NewMockMessager creates a new mock instance.

NewMockQueuer creates a new mock instance.

NewMockSubber creates a new mock instance.

NewMQTT builds a new Queuer and returns it and an error value.

NewNSQ builds a new Queuer and returns it and an error value.

Constants used for the configuration of MQTT behavior.

ErrTimeout is returned when a Queue operation times out.

Prime is the single-byte payload used to prime a Queue.

MockMessager is a mock of Messager interface.

MockMessagerMockRecorder is the mock recorder for MockMessager.

MockQueuer is a mock of Queuer interface.

MockQueuerMockRecorder is the mock recorder for MockQueuer.

MockSubber is a mock of Subber interface.

MockSubberMockRecorder is the mock recorder for MockSubber.

Messager defines the methods provided by a Message.

Queuer defines the methods provided by a Queue.

Subber defines the methods provided by a Subscription.