public void connect ( String url , String virtualHost , String username , String password ) { if ( websocket != null ) { throw new IllegalStateException ( "AmqpClient already connected" ) ; } this . readyState = ReadyState . CONNECTING ; this . url = url ; this . userName = username ; this . password = password ; this . virtualHost = virtualHost ; this . hasNegotiated = false ; asyncClient . getStateMachine ( ) . enterState ( "handshaking" , "" , this . url ) ; }
Connect to AMQP Broker via Kaazing Gateway