src/main/java/org/cloudi/API.java
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);
    }
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);
    }
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.

@param pattern  the service name pattern

@throws InvalidInputException not subscribed to service name pattern
Unsubscribes from a service name pattern .