otfbot.services.amqp.AmqpFactory

class documentation

class AmqpFactory(protocol.ReconnectingClientFactory): (source)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method buildProtocol Undocumented
Method clientConnectionFailed Undocumented
Method clientConnectionLost Undocumented
Method read Configure an exchange to be read from.
Method send_message Send a message.
Instance Variable client Undocumented
Instance Variable config Undocumented
Instance Variable deferred Undocumented
Instance Variable delegate Undocumented
Instance Variable initial_deferred_fired Undocumented
Instance Variable logger Undocumented
Instance Variable p Undocumented
Instance Variable parent Undocumented
Instance Variable password Undocumented
Instance Variable queued_messages Undocumented
Instance Variable read_list Undocumented
Instance Variable root Undocumented
Instance Variable spec Undocumented
Instance Variable user Undocumented
Instance Variable vhost Undocumented
def __init__(self, root, parent, spec_file=None, vhost=None, user=None, password=None): (source)

Undocumented

def buildProtocol(self, addr): (source)

Undocumented

def clientConnectionFailed(self, connector, reason): (source)

Undocumented

def clientConnectionLost(self, connector, reason): (source)

Undocumented

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

Configure an exchange to be read from.

def send_message(self, exchange=None, routing_key=None, msg=None): (source)

Send a message.

client = (source)

Undocumented

config = (source)

Undocumented

deferred = (source)

Undocumented

delegate = (source)

Undocumented

initial_deferred_fired: bool = (source)

Undocumented

logger = (source)

Undocumented

p = (source)

Undocumented

parent = (source)

Undocumented

password = (source)

Undocumented

queued_messages: list = (source)

Undocumented

read_list: list = (source)

Undocumented

root = (source)

Undocumented

spec = (source)

Undocumented

user = (source)

Undocumented

vhost = (source)

Undocumented