Initialize takes a Config parameter and initializes a connection, channel, topic exchange, command exchange and service specific command and response queues.

LoadConfiguration loads configuration values from RABBITMQ_HOST, RABBITMQ_USER and RABBITMQ_PASS.

MatchContentType returns a topic message filter that returns true for all messages where the content type matches the supplied content type case insensitive.

NewPingCommand instantiates a new ping command.

NewPingCommandHandler returns a callback function to be called when ping commands are received.

NewPongResponse instantiates a new pong response from a ping command.

PingCommandContentType is the content type for a ping command.

PongResponseContentType is the content type for a pong response.

Config is an encapsulating context that wraps configuration information used by the initialization methods of the messaging library.

IncomingTopicMessageMock is a mock implementation of IncomingTopicMessage.

MsgContextMock is a mock implementation of MsgContext.

PingCommand is a utility command to check the messenger connection.

PongResponse is a utility response to check the messenger connection.

Command is an interface used when handling commands.

MsgContext encapsulates the underlying messaging primitives, as well as their associated configuration.

TopicMessage is an interface used when sending messages to make sure that messages are sent to the correct topic with correct content type.

CommandHandler is a callback type to be used for dispatching incoming commands.

MessageFilter allows a subscriber to supply a filter function that decides if a received message should be delivered to the handler or not.

TopicMessageHandler is a callback type that should be passed to RegisterTopicMessageHandler to receive messages from topics.