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