public void unsubscribe ( final String pattern ) throws InvalidInputException { final String s = this . prefix + pattern ; LinkedList < FunctionInterface9 > callback_list = this . callbacks . get ( s ) ; if ( callback_list == null ) { throw new InvalidInputException ( ) ; } else { callback_list . removeFirst ( ) ; if ( callback_list . isEmpty ( ) ) { this . callbacks . remove ( s ) ; } } OtpOutputStream unsubscribe = new OtpOutputStream ( ) ; unsubscribe . write ( OtpExternal . versionTag ) ; final OtpErlangObject [ ] tuple = { new OtpErlangAtom ( "unsubscribe" ) , new OtpErlangString ( pattern ) } ; unsubscribe . write_any ( new OtpErlangTuple ( tuple ) ) ; send ( unsubscribe ) ; }
Unsubscribes from a service name pattern .