@ Override public void close ( ) { try { callbackRegistry . acceptConnectionStateChange ( BitfinexConnectionStateEnum . DISCONNECTION_INIT ) ; logger . debug ( "close() called" ) ; if ( heartbeatThread != null ) { heartbeatThread . interrupt ( ) ; heartbeatThread = null ; } if ( websocketEndpoint != null ) { websocketEndpoint . close ( ) ; websocketEndpoint = null ; } connectionStateChange ( BitfinexConnectionStateEnum . DISCONNECTION_SUCCESS ) ; } catch ( final Exception e ) { connectionStateChange ( BitfinexConnectionStateEnum . DISCONNECTION_FAILED ) ; throw new BitfinexClientException ( e ) ; } }
Disconnect the websocket