code: @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);
  		}
  	}
docs: Disconnect the websocket