BaseAdapter

Message Queue Base Adapter Interface.

class message_queue.adapters.base_adapter.BaseAdapter

Bases: object

close()

Close connection.

configurate_queue()

Define the queue configuration.

connect()

Connect to queue.

consume()

Consume message from the queue.

consume_callback()

Callback method to execute in the consume.

format_message()

Format message to send to the queue.

send()

Publish a message to the queue.