ReceiveClientAsync Class

An AMQP client for receiving messages asynchronously.

Inheritance
ReceiveClientAsync
ReceiveClientAsync

Constructor

ReceiveClientAsync(source, auth=None, client_name=None, loop=None, debug=False, timeout=0, auto_complete=True, error_policy=None, keep_alive_interval=None, **kwargs)

Parameters

target
str, bytes or Source
Required

The source AMQP service endpoint. This can either be the URI as a string or a ~uamqp.address.Source object.

auth
AMQPAuth
default value: None

Authentication for the connection. This should be one of the subclasses of uamqp.authentication.AMQPAuth. Currently this includes:

  • uamqp.authentication.SASLAnonymous

  • uamqp.authentication.SASLPlain

  • uamqp.authentication.SASTokenAsync

  • uamqp.authentication.JWTTokenAsync

If no authentication is supplied, SASLAnnoymous will be used by default.

client_name
str or bytes
default value: None

The name for the client, also known as the Container ID. If no name is provided, a random GUID will be used.

debug
bool
default value: None

Whether to turn on network trace logs. If True, trace logs will be logged at INFO level. Default is False.

timeout
float
default value: False

A timeout in milliseconds. The receiver will shut down if no new messages are received after the specified timeout. If set to 0, the receiver will never timeout and will continue to listen. The default is 0. Set shutdown_after_timeout to False if keeping the receiver open after timeout is needed.

shutdown_after_timeout
bool
default value: 0

Whether to automatically shutdown the receiver if no new messages are received after the specified timeout. Default is True.

auto_complete
bool
default value: True

Whether to automatically settle message received via callback or via iterator. If the message has not been explicitly settled after processing the message will be accepted. Alternatively, when used with batch receive, this setting will determine whether the messages are pre-emptively settled during batching, or otherwise let to the user to be explicitly settled.

error_policy
ErrorPolicy
default value: None

A policy for parsing errors on link, connection and message disposition to determine whether the error should be retryable.

keep_alive_interval
int
default value: None

If set, a thread will be started to keep the connection alive during periods of user inactivity. The value will determine how long the thread will sleep (in seconds) between pinging the connection. If 0 or None, no thread will be started.

send_settle_mode
SenderSettleMode
Required

The mode by which to settle message send operations. If set to Unsettled, the client will wait for a confirmation from the service that the message was successfully sent. If set to 'Settled', the client will not wait for confirmation and assume success.

receive_settle_mode
ReceiverSettleMode
Required

The mode by which to settle message receive operations. If set to PeekLock, the receiver will lock a message once received until the client accepts or rejects the message. If set to ReceiveAndDelete, the service will assume successful receipt of the message and clear it from the queue. The default is PeekLock.

desired_capabilities
AMQPValue
Required

The extension capabilities desired from the peer endpoint. To create a desired_capabilities object, please do as follows:

    1. Create an array of desired capability symbols: capabilities_symbol_array = [types.AMQPSymbol(string)]
    1. Transform the array to AMQPValue object: utils.data_factory(types.AMQPArray(capabilities_symbol_array))
max_message_size
int
Required

The maximum allowed message size negotiated for the Link.

link_properties
dict
Required

Metadata to be sent in the Link ATTACH frame.

prefetch
int
Required

The receiver Link credit that determines how many messages the Link will attempt to handle per connection iteration. The default is 300.

max_frame_size
int
Required

Maximum AMQP frame size. Default is 63488 bytes.

channel_max
int
Required

Maximum number of Session channels in the Connection.

idle_timeout
int
Required

Timeout in milliseconds after which the Connection will close if there is no further activity.

properties
dict
Required

Connection properties.

remote_idle_timeout_empty_frame_send_ratio
float
Required

Ratio of empty frames to idle time for Connections with no activity. Value must be between 0.0 and 1.0 inclusive. Default is 0.5.

incoming_window
int
Required

The size of the allowed window for incoming messages.

outgoing_window
int
Required

The size of the allowed window for outgoing messages.

handle_max
int
Required

The maximum number of concurrent link handles.

on_attach
<xref:func>[Source, Target, dict, AMQPConnectionError]
Required

A callback function to be run on receipt of an ATTACH frame. The function must take 4 arguments: source, target, properties and error.

encoding
str
Required

The encoding to use for parameters supplied as strings. Default is 'UTF-8'

Methods

close_async

Asynchonously close the receive client.

receive_message_batch_async

Receive a batch of messages asynchronously. This method will return as soon as some messages are available rather than waiting to achieve a specific batch size, and therefore the number of messages returned per call will vary up to the maximum allowed.

If the receive client is configured with auto_complete=True then the messages received in the batch returned by this function will already be settled. Alternatively, if auto_complete=False, then each message will need to be explicitly settled before it expires and is released.

receive_messages_async

Receive messages asynchronously. This function will run indefinitely, until the client closes either via timeout, error or forced interruption (e.g. keyboard interrupt).

If the receive client is configured with auto_complete=True then the messages that have not been settled on completion of the provided callback will automatically be accepted provided it has not expired. If an error occurs or the message has expired it will be released. Alternatively if auto_complete=False, each message will need to be explicitly settled during the callback, otherwise it will be released.

receive_messages_iter_async

Receive messages by asynchronous generator. Messages returned in the generator have already been accepted - if you wish to add logic to accept or reject messages based on custom criteria, pass in a callback.

If the receive client is configured with auto_complete=True then the messages received from the iterator returned by this function will be automatically settled when the iterator is incremented. Alternatively, if auto_complete=False, then each message will need to be explicitly settled before it expires and is released.

redirect_async

Redirect the client endpoint using a Link DETACH redirect response.

close_async

Asynchonously close the receive client.

async close_async()

receive_message_batch_async

Receive a batch of messages asynchronously. This method will return as soon as some messages are available rather than waiting to achieve a specific batch size, and therefore the number of messages returned per call will vary up to the maximum allowed.

If the receive client is configured with auto_complete=True then the messages received in the batch returned by this function will already be settled. Alternatively, if auto_complete=False, then each message will need to be explicitly settled before it expires and is released.

async receive_message_batch_async(max_batch_size=None, on_message_received=None, timeout=0)

Parameters

max_batch_size
int
default value: None

The maximum number of messages that can be returned in one call. This value cannot be larger than the prefetch value, and if not specified, the prefetch value will be used.

on_message_received
callable[Message]
default value: None

A callback to process messages as they arrive from the service. It takes a single argument, a ~uamqp.message.Message object.

timeout
float
default value: 0

Timeout in milliseconds for which to wait to receive any messages. If no messages are received in this time, an empty list will be returned. If set to 0, the client will continue to wait until at least one message is received. The default is 0.

receive_messages_async

Receive messages asynchronously. This function will run indefinitely, until the client closes either via timeout, error or forced interruption (e.g. keyboard interrupt).

If the receive client is configured with auto_complete=True then the messages that have not been settled on completion of the provided callback will automatically be accepted provided it has not expired. If an error occurs or the message has expired it will be released. Alternatively if auto_complete=False, each message will need to be explicitly settled during the callback, otherwise it will be released.

async receive_messages_async(on_message_received)

Parameters

on_message_received
callable[Message]
Required

A callback to process messages as they arrive from the service. It takes a single argument, a ~uamqp.message.Message object.

receive_messages_iter_async

Receive messages by asynchronous generator. Messages returned in the generator have already been accepted - if you wish to add logic to accept or reject messages based on custom criteria, pass in a callback.

If the receive client is configured with auto_complete=True then the messages received from the iterator returned by this function will be automatically settled when the iterator is incremented. Alternatively, if auto_complete=False, then each message will need to be explicitly settled before it expires and is released.

receive_messages_iter_async(on_message_received=None)

Parameters

on_message_received
callable[Message]
default value: None

A callback to process messages as they arrive from the service. It takes a single argument, a ~uamqp.message.Message object.

Return type

<xref:Generator>[Message]

redirect_async

Redirect the client endpoint using a Link DETACH redirect response.

async redirect_async(redirect, auth)

Parameters

redirect
LinkRedirect
Required

The Link DETACH redirect details.

auth
AMQPAuth
Required

Authentication credentials to the redirected endpoint.