adds a connection to some other message hub . outgoing messages are forwarded to this connection , and incoming messages are received from it . concode_field_sep Discard DISCARD concode_elem_sep Dispatch<Object> dispatch concode_elem_sep HubStateListener stateListener concode_elem_sep String displayName concode_elem_sep ConnectionState connectionState concode_elem_sep RejectedMessageListener listener concode_elem_sep Class<T> type concode_elem_sep IncomingQueue incomingQueue concode_elem_sep Lock lock concode_elem_sep ConnectionSet connections concode_elem_sep ChannelIdentifier channelIdentifier concode_elem_sep Action<? super Throwable> errorHandler concode_elem_sep OutgoingQueue outgoingQueue concode_elem_sep Connection<InterHubMessage> connection concode_elem_sep State state concode_elem_sep StoppableExecutor workers concode_elem_sep EndPointQueue queue concode_field_sep void addHandler concode_elem_sep void onConnect concode_elem_sep void onDisconnect concode_elem_sep void dispatch concode_elem_sep void dispatch concode_elem_sep void stop concode_elem_sep Dispatch<T> getOutgoing concode_elem_sep void run concode_elem_sep void run concode_elem_sep void run concode_elem_sep String toString concode_elem_sep void assertRunning concode_elem_sep void requestStop concode_elem_sep void messageDiscarded
void function ( Connection < InterHubMessage > arg0 ) { lock . lock ( ) ; try { assertRunning ( "srini_string" ) ; ConnectionState loc0 = connections . add ( arg0 ) ; workers . execute ( new ConnectionDispatch ( loc0 ) ) ; workers . execute ( new ConnectionReceive ( loc0 ) ) ; } finally { lock . unlock ( ) ; } }