@ Override public void onNext ( final T event ) { if ( LOG . isLoggable ( Level . FINE ) ) { LOG . log ( Level . FINE , "remoteid: {0}\n{1}" , new Object [ ] { remoteId . getSocketAddress ( ) , event . toString ( ) } ) ; } handler . onNext ( new RemoteEvent < T > ( myId . getSocketAddress ( ) , remoteId . getSocketAddress ( ) , seqGen . getNextSeq ( remoteId . getSocketAddress ( ) ) , event ) ) ; }
Sends the event to the event handler running remotely .