public void unsubscribe ( final Subscription < T > subscription ) { final T token = subscription . getToken ( ) ; LOG . log ( Level . FINER , "RemoteManager: {0} token {1}" , new Object [ ] { this . name , token } ) ; if ( token instanceof Exception ) { this . transport . registerErrorHandler ( null ) ; } else if ( token instanceof Tuple2 ) { this . tupleToHandlerMap . remove ( token ) ; } else if ( token instanceof Class ) { this . msgTypeToHandlerMap . remove ( token ) ; } else { throw new RemoteRuntimeException ( "Unknown subscription type: " + subscription . getClass ( ) . getCanonicalName ( ) ) ; } }
Unsubscribes a handler .