otfbot.services.amqpView Source (View In Hierarchy)
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||_channel_open||Called when the channel is open.|
|Method||_send_message||Send a single message.|
|Method||_read_item||Callback function which is called when an item is read.|
Called when a connection has been made.
Called when the connection has been authenticated.
Called when the channel is open.
Add an exchange to the list of exchanges to read from.
If connected, send all waiting messages.
This function does the work to read from an exchange.
Send a single message.
Callback function which is called when an item is read.