kombu.transport.amqplib

amqplib transport.

Transport

class kombu.transport.amqplib.Transport(client, **kwargs)[source]
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)[source]

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)[source]
Transport.default_connection_params
Transport.default_port = 5672
Transport.drain_events(connection, **kwargs)[source]
Transport.driver_name = 'amqplib'
Transport.driver_type = 'amqp'
Transport.establish_connection()[source]

Establish connection to the AMQP broker.

Transport.get_manager(*args, **kwargs)[source]
Transport.is_alive(connection)[source]
Transport.register_with_event_loop(connection, loop)[source]
Transport.supports_ev = True
Transport.verify_connection(connection)[source]

Connection

class kombu.transport.amqplib.Connection(*args, **kwargs)[source]
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)[source]
Connection.connected = True
Connection.drain_events(timeout=None)[source]

Wait for an event on a channel.

Connection.read_timeout(timeout=None)[source]

Channel

class kombu.transport.amqplib.Channel(*args, **kwargs)[source]
class Message(channel, msg, **kwargs)
Channel.basic_cancel(consumer_tag, **kwargs)[source]
Channel.basic_consume(*args, **kwargs)[source]
Channel.close()[source]
Channel.events = {'basic_return': set([])}
Channel.message_to_python(raw_message)[source]

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)[source]

Encapsulate data into a AMQP message.

Message

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