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)¶
-
class
Connection¶
-
class
kombu.transport.amqplib.Connection(*args, **kwargs)¶ -
AMQP_PROTOCOL_HEADER= 'AMQP\x01\x01\x08\x00'¶
-
Connection¶ alias of
NA
-
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.
-
class