uamqp package

Packages

async_ops
authentication

Gets the current platform information.

get_platform_info()

Type	Description
str

Receive a single message from an AMQP endpoint.

receive_message(source, auth=None, timeout=0, debug=False)

Name	Description
source Required	str, bytes or Source The AMQP source endpoint to receive from.
auth	AMQPAuth The authentication credentials for the endpoint. This should be one of the subclasses of uamqp.authentication.AMQPAuth. Currently this includes: uamqp.authentication.SASLAnonymous uamqp.authentication.SASLPlain uamqp.authentication.SASTokenAuth If no authentication is supplied, SASLAnnoymous will be used by default. Default value: None
timeout	The timeout in milliseconds after which to return None if no messages are retrieved. If set to 0 (the default), the receiver will not timeout and will continue to wait for messages until interrupted. Default value: 0
debug	bool Whether to turn on network trace logs. If True, trace logs will be logged at INFO level. Default is False. Default value: False

Type	Description
Message, None

Receive a batch of messages from an AMQP endpoint.

receive_messages(source, auth=None, max_batch_size=None, timeout=0, debug=False, **kwargs)

Name	Description
source Required	str, bytes or Source The AMQP source endpoint to receive from.
auth	AMQPAuth The authentication credentials for the endpoint. This should be one of the subclasses of ~uamqp.authentication.AMQPAuth. Currently this includes: uamqp.authentication.SASLAnonymous uamqp.authentication.SASLPlain uamqp.authentication.SASTokenAuth If no authentication is supplied, SASLAnnoymous will be used by default. Default value: None
max_batch_size	The maximum number of messages to return in a batch. If the receiver receives a smaller number than this, it will not wait to return them so the actual number returned can be anything up to this value. If the receiver reaches a timeout, an empty list will be returned. Default value: None
timeout	The timeout in milliseconds after which to return if no messages are retrieved. If set to 0 (the default), the receiver will not timeout and will continue to wait for messages until interrupted. Default value: 0
debug	bool Whether to turn on network trace logs. If True, trace logs will be logged at INFO level. Default is False. Default value: False

Type	Description
list[Message]

Send a single message to AMQP endpoint.

send_message(target, data, auth=None, debug=False)

Name	Description
target Required	str, bytes or Target The target AMQP endpoint.
data Required	str, bytes or Message The contents of the message to send.
auth	AMQPAuth The authentication credentials for the endpoint. This should be one of the subclasses of uamqp.authentication.AMQPAuth. Currently this includes: uamqp.authentication.SASLAnonymous uamqp.authentication.SASLPlain uamqp.authentication.SASTokenAuth If no authentication is supplied, SASLAnnoymous will be used by default. Default value: None
debug	bool Whether to turn on network trace logs. If True, trace logs will be logged at INFO level. Default is False. Default value: False

Type	Description
list[MessageState]	A list of states for each message sent.