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.

NewPingCommand instantiates a new ping command.

NewPingCommandHandler returns a callback function to be called when ping commandsare 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.

Error encapsulates a lower level error together with an error message provided by the caller that experienced the error.

PingCommand is a utility command to check the messenger connection.

PongResponse is a utility response to check the messenger connection.

CommandMessage is an interface used when sending commands.

CommandMessageWrapper is used to wrap an incoming command message.

Context 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.

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