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.
connection_errors
= (<class 'amqp.exceptions.ConnectionError'>, <class 'kombu.transport.amqplib.NA'>, <class 'socket.error'>, <type 'exceptions.IOError'>, <type 'exceptions.OSError'>, <type 'exceptions.AttributeError'>)¶
-
Transport.
default_connection_params
¶
-
Transport.
default_port
= 5672¶
-
Transport.
driver_name
= 'amqplib'¶
-
Transport.
driver_type
= 'amqp'¶
-
Transport.
supports_ev
= True¶
-
class