Finish up, by clearing the buffer.

GetMessages from the AMQP server, calling the function each time a message is received.

SendMessage down a topic, with the JSON form of the content.

SendMessageBytes down a topic, with bytes as content.

Context is used to identify the AMQP server in logging.

EnvDeadLetterEnabled to disable the use of dead letter queues (disabling with "false" implies disabling retries).

EnvGoroutinesPerQueue for the number of goroutines to run per topic, defaults to 1.

EnvMessageLoggingEnabled to log all incoming messages using a log debug if set to anything other than "".

EnvMessageRetries to attempt until giving up - defaults to 5 if not set!.

EnvQueueAddr is the address to access RabbitMQ.

ExchangeName to use for AMQP queues.

ExchangeType to use for routing messages inside the queue.

RandomConsumerPrefixLength to append to the worker id.