close and remove zeppelinconnection concode_field_sep Logger LOG concode_elem_sep String zeppelinhubToken concode_elem_sep URI zeppelinWebsocketUrl concode_elem_sep WebSocketClient wsClient concode_elem_sep ZeppelinClient instance concode_elem_sep ConcurrentHashMap<String,Session> zeppelinConnectionMap concode_elem_sep Gson gson concode_elem_sep SchedulerService schedulerService concode_elem_sep Authentication authModule concode_elem_sep int min concode_field_sep WebSocketClient createNewWebsocketClient concode_elem_sep Session openNoteSession concode_elem_sep boolean credentialsAvailable concode_elem_sep void pingAllNotes concode_elem_sep void start concode_elem_sep boolean isSessionOpen concode_elem_sep void handleMsgFromZeppelin concode_elem_sep int countConnectedNotes concode_elem_sep String serialize concode_elem_sep void addRoutines concode_elem_sep void stop concode_elem_sep void removeAllZeppelinConnections concode_elem_sep ZeppelinClient initialize concode_elem_sep ZeppelinClient getInstance concode_elem_sep Message zeppelinGetNoteMsg concode_elem_sep Session getNoteSession concode_elem_sep void send concode_elem_sep Session getZeppelinConnection concode_elem_sep Message deserialize
void function ( String arg0 ) { if ( zeppelinConnectionMap . containsKey ( arg0 ) ) { Session loc0 = zeppelinConnectionMap . get ( arg0 ) ; if ( loc0 . isOpen ( ) ) { loc0 . close ( ) ; } zeppelinConnectionMap . remove ( arg0 ) ; } LOG . info ( "srini_string" , arg0 ) ; }