kombu.transport.amqplib

amqplib transport.

Transport

class kombu.transport.amqplib.Transport(client, **kwargs)

class Connection(*args, **kwargs)

channel(channel_id=None)

connected = True

drain_events(timeout=None)

Wait for an event on a channel.

read_timeout(timeout=None)

Transport.channel_errors = (<class 'amqp.exceptions.ChannelError'>, <class 'kombu.transport.amqplib.NA'>)

Transport.close_connection(connection)

Close the AMQP broker connection.

Transport.connection_errors = (<class 'amqp.exceptions.ConnectionError'>, <class 'kombu.transport.amqplib.NA'>, <class 'socket.error'>, <type 'exceptions.IOError'>, <type 'exceptions.OSError'>, <type 'exceptions.AttributeError'>)

Transport.create_channel(connection)

Transport.default_connection_params

Transport.default_port = 5672

Transport.drain_events(connection, **kwargs)

Transport.driver_name = 'amqplib'

Transport.driver_type = 'amqp'

Transport.establish_connection()

Establish connection to the AMQP broker.

Transport.get_manager(*args, **kwargs)

Transport.is_alive(connection)

Transport.register_with_event_loop(connection, loop)

Transport.supports_ev = True

Transport.verify_connection(connection)

Connection

class kombu.transport.amqplib.Connection(*args, **kwargs)

AMQP_PROTOCOL_HEADER = 'AMQP\x01\x01\x08\x00'

Connection

alias of NA

class SSLTransport(host, connect_timeout, ssl)

read_frame()

class Connection.TCPTransport

read_frame()

Connection.channel(channel_id=None)

Connection.connected = True

Connection.drain_events(timeout=None)

Wait for an event on a channel.

Connection.read_timeout(timeout=None)

Channel

class kombu.transport.amqplib.Channel(*args, **kwargs)

class Message(channel, msg, **kwargs)

Channel.basic_cancel(consumer_tag, **kwargs)

Channel.basic_consume(*args, **kwargs)

Channel.close()

Channel.events = {'basic_return': set([])}

Channel.message_to_python(raw_message)

Convert encoded message body back to a Python value.

Channel.prepare_message(body, priority=None, content_type=None, content_encoding=None, headers=None, properties=None)

Encapsulate data into a AMQP message.

Message

class kombu.transport.amqplib.Message(channel, msg, **kwargs)