start client connection and return immediately . concode_field_sep Set<String> subscriptions concode_elem_sep ByteBuffer readBuffer concode_elem_sep List<FanoutListener> listeners concode_elem_sep SocketChannel socketCh concode_elem_sep AtomicBoolean isAutomaticReconnect concode_elem_sep AtomicBoolean isConnected concode_elem_sep int reconnectTimeout concode_elem_sep CharsetDecoder decoder concode_elem_sep ByteBuffer writeBuffer concode_elem_sep int clientTimeout concode_elem_sep Thread clientThread concode_elem_sep int port concode_elem_sep AtomicBoolean isRunning concode_elem_sep boolean resubscribe concode_elem_sep String host concode_elem_sep Selector selector concode_elem_sep String id concode_elem_sep Logger logger concode_field_sep String read concode_elem_sep void setAutomaticReconnect concode_elem_sep void subscribe concode_elem_sep void ping concode_elem_sep boolean isAutomaticReconnect concode_elem_sep boolean isConnected concode_elem_sep void resetState concode_elem_sep void fireAnnouncement concode_elem_sep boolean processReply concode_elem_sep void main concode_elem_sep void run concode_elem_sep void removeListener concode_elem_sep void pong concode_elem_sep void pong concode_elem_sep void firePong concode_elem_sep void announce concode_elem_sep void startSynchronously concode_elem_sep void stop concode_elem_sep void closeChannel concode_elem_sep void unsubscribe concode_elem_sep void confirmConnection concode_elem_sep boolean write concode_elem_sep void announcement concode_elem_sep void announcement concode_elem_sep void addListener concode_elem_sep void status
void function ( ) { if ( isRunning . get ( ) ) { logger . warn ( "srini_string" ) ; return ; } clientThread = new Thread ( this , "srini_string" ) ; clientThread . start ( ) ; }