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 'amqplib.client_0_8.exceptions.AMQPChannelException'>)¶
-
Transport.
connection_errors
= (<class 'amqp.exceptions.ConnectionError'>, <class 'amqplib.client_0_8.exceptions.AMQPConnectionException'>, <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
Connection¶
-
class
kombu.transport.amqplib.
Connection
(*args, **kwargs)[source]¶ -
-
close
(reply_code=0, reply_text='', method_sig=(0, 0))[source]¶ request a connection close
This method indicates that the sender wants to close the connection. This may be due to internal conditions (e.g. a forced shut-down) or due to an error handling a specific method, i.e. an exception. When a close is due to an exception, the sender provides the class and method id of the method which caused the exception.
RULE:
After sending this method any received method except the Close-OK method MUST be discarded.RULE:
The peer sending this method MAY use a counter or timeout to detect failure of the other peer to respond correctly with the Close-OK method.RULE:
When a server receives the Close method from a client it MUST delete all server-side resources associated with the client’s context. A client CANNOT reconnect to a context after sending or receiving a Close method.- PARAMETERS:
reply_code: short
The reply code. The AMQ reply codes are defined in AMQ RFC 011.reply_text: shortstr
The localised reply text. This text can be logged as an aid to resolving issues.class_id: short
failing method class
When the close is provoked by a method exception, this is the class of the method.
method_id: short
failing method ID
When the close is provoked by a method exception, this is the ID of the method.
-
connected
= True¶
-
dispatch_method
(method_sig, args, content)¶
-
wait
(allowed_methods=None)¶ Wait for a method that matches our allowed_methods parameter (the default value of None means match any method), and dispatch to it.
-