in uamqp/async_ops/client_async.py [0:0]
def __init__(
self,
remote_address,
auth=None,
client_name=None,
loop=None,
debug=False,
error_policy=None,
keep_alive_interval=None,
**kwargs):
self._internal_kwargs = get_dict_with_loop_if_needed(loop)
super(AMQPClientAsync, self).__init__(
remote_address,
auth=auth,
client_name=client_name,
debug=debug,
error_policy=error_policy,
keep_alive_interval=keep_alive_interval,
**kwargs)
# AMQP object settings
self.connection_type = ConnectionAsync
self.session_type = SessionAsync