in uamqp/async_ops/sender_async.py [0:0]
def __init__(self, session, source, target,
name=None,
send_settle_mode=constants.SenderSettleMode.Unsettled,
receive_settle_mode=constants.ReceiverSettleMode.PeekLock,
max_message_size=constants.MAX_MESSAGE_LENGTH_BYTES,
link_credit=None,
properties=None,
error_policy=None,
debug=False,
encoding='UTF-8',
desired_capabilities=None,
loop=None):
self._internal_kwargs = get_dict_with_loop_if_needed(loop)
super(MessageSenderAsync, self).__init__(
session, source, target,
name=name,
send_settle_mode=send_settle_mode,
receive_settle_mode=receive_settle_mode,
max_message_size=max_message_size,
link_credit=link_credit,
properties=properties,
error_policy=error_policy,
debug=debug,
encoding=encoding,
desired_capabilities=desired_capabilities)