#NEWLINE# def __init__( self , hostname , username , password , port = 5672 , **kwargs ) : #NEWLINE# #INDENT# '\n        :param str hostname: Hostname\n        :param str username: Username\n        :param str password: Password\n        :param int port: Server port\n        :param str virtual_host: Virtualhost\n        :param int heartbeat: RabbitMQ Heartbeat interval\n        :param int|float timeout: Socket timeout\n        :param bool ssl: Enable SSL\n        :param dict ssl_options: SSL kwargs (from ssl.wrap_socket)\n        :param bool lazy: Lazy initialize the connection\n        :return:\n        ' #NEWLINE# super ( Connection , self ) . __init__ ( ) #NEWLINE# self . parameters = { #NEWLINE# #INDENT# 'hostname' : hostname , #NEWLINE# 'username' : username , #NEWLINE# 'password' : username , #NEWLINE# 'port' : port , #NEWLINE# 'virtual_host' : kwargs . get ( 'virtual_host' , '/' ) , #NEWLINE# 'heartbeat' : kwargs . get ( 'heartbeat' , 60 ) , #NEWLINE# 'timeout' : kwargs . get ( 'timeout' , 30 ) , #NEWLINE# 'ssl' : kwargs . get ( 'ssl' , False ) , #NEWLINE# 'ssl_options' : kwargs . get ( 'ssl_options' , { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } ) , #NEWLINE# #UNINDENT# } #NEWLINE# self . _validate_parameters ( ) #NEWLINE# self . heartbeat = Heartbeat ( self . parameters [ 'heartbeat' ] ) #NEWLINE# self . _io = IO ( self . parameters , on_read = self . _read_buffer ) #NEWLINE# self . _channel0 = Channel0 ( self ) #NEWLINE# self . _channels = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# if ( not kwargs . get ( 'lazy' , False ) ) : #NEWLINE# #INDENT# self . open ( )