CopyOnWriteArrayList < WebSocketSessionRequest > function ( int arg0 , String arg1 ) { ConcurrentHashMap < String , CopyOnWriteArrayList < WebSocketSessionRequest >> loc0 = outputEventAdaptorSessionMap . get ( arg0 ) ; if ( loc0 != null ) { return loc0 . get ( arg1 ) ; } return null ; }
used to return registered sessions per streamid concode_field_sep ConcurrentHashMap<Integer,ConcurrentHashMap<String,CopyOnWriteArrayList<WebSocketSessionRequest>>> outputEventAdaptorSessionMap concode_field_sep LinkedBlockingDeque<Object> getEvents concode_elem_sep void unsubscribeWebsocket concode_elem_sep void subscribeWebsocket