question: before the websocket is used , it 's recommended to call this method to ensure that any exceptions caught while processing the messages received are acknowledged . concode_field_sep int ioThreadMultiplier concode_elem_sep PubSubMessageCodec<Object> codec concode_elem_sep String password concode_elem_sep Logger logger concode_elem_sep String loginUrl concode_elem_sep AtomicReference<Throwable> throwable concode_elem_sep AsyncHttpClient client concode_elem_sep WebSocket connection concode_elem_sep ObjectMapper mapper concode_elem_sep String userName concode_elem_sep URI uri concode_field_sep void setPassword concode_elem_sep void onError concode_elem_sep void onError concode_elem_sep void openConnectionAsync concode_elem_sep void subscribe concode_elem_sep void openConnection concode_elem_sep void setUri concode_elem_sep void subscribeNumSubscribers concode_elem_sep void setIoThreadMultiplier concode_elem_sep void setLoginUrl concode_elem_sep boolean isConnectionOpen concode_elem_sep void onClose concode_elem_sep void onClose concode_elem_sep void unsubscribeNumSubscribers concode_elem_sep void onOpen concode_elem_sep void onOpen concode_elem_sep void setUserName concode_elem_sep void unsubscribe concode_elem_sep void publish concode_elem_sep void onMessage concode_elem_sep void onMessage concode_elem_sep void setup concode_elem_sep void teardown
target: void function ( ) { if ( throwable . get ( ) == null ) { if ( connection == null ) { throw new IOException ( "srini_string" ) ; } return ; } Throwable loc0 = throwable . get ( ) ; if ( loc0 instanceof IOException ) { throw ( IOException ) loc0 ; } else { throw Throwables . propagate ( loc0 ) ; } }