The protocol is created and destroyed each time a connection is created and lost.

Method connectionMade Called when a connection has been made.
Method read Add an exchange to the list of exchanges to read from.
Method send If connected, send all waiting messages.
Method setup_read This function does the work to read from an exchange.
Method _authenticated Called when the connection has been authenticated.
Method _got_channel Undocumented
Method _channel_open Called when the channel is open.
Method _channel_open_failed Undocumented
Method _got_channel_failed Undocumented
Method _authentication_failed Undocumented
Method _send_message Send a single message.
Method _send_message_err Undocumented
Method _read_item Callback function which is called when an item is read.
Method _read_item_err Undocumented
def connectionMade(self): (source)

Called when a connection has been made.

def _authenticated(self, ignore): (source)

Called when the connection has been authenticated.

def _got_channel(self, chan): (source)
Undocumented
def _channel_open(self, arg): (source)

Called when the channel is open.

def read(self, exchange, routing_key, callback): (source)

Add an exchange to the list of exchanges to read from.

def send(self): (source)

If connected, send all waiting messages.

@inlineCallbacks
def setup_read(self, exchange, routing_key, callback): (source)

This function does the work to read from an exchange.

def _channel_open_failed(self, error): (source)
Undocumented
def _got_channel_failed(self, error): (source)
Undocumented
def _authentication_failed(self, error): (source)
Undocumented
@inlineCallbacks
def _send_message(self, exchange, routing_key, msg): (source)

Send a single message.

def _send_message_err(self, error): (source)
Undocumented
def _read_item(self, item, queue, callback): (source)

Callback function which is called when an item is read.

def _read_item_err(self, error): (source)
Undocumented
API Documentation for OtfBot, generated by pydoctor at 2020-03-04 02:00:06.