src/main/java/org/cloudi/API.java
public void subscribe(final String pattern,
                          final FunctionInterface9 callback)
    {
        final String s = this.prefix + pattern;
        LinkedList<FunctionInterface9> callback_list = this.callbacks.get(s);
        if (callback_list == null)
        {
            callback_list = new LinkedList<FunctionInterface9>();
            callback_list.addLast(callback);
            this.callbacks.put(s, callback_list);
        }
        else
        {
            callback_list.addLast(callback);
        }
        OtpOutputStream subscribe = new OtpOutputStream();
        subscribe.write(OtpExternal.versionTag);
        final OtpErlangObject[] tuple = {new OtpErlangAtom("subscribe"),
                                         new OtpErlangString(pattern)};
        subscribe.write_any(new OtpErlangTuple(tuple));
        send(subscribe);
    }
public void subscribe(final String pattern,
                          final FunctionInterface9 callback)
    {
        final String s = this.prefix + pattern;
        LinkedList<FunctionInterface9> callback_list = this.callbacks.get(s);
        if (callback_list == null)
        {
            callback_list = new LinkedList<FunctionInterface9>();
            callback_list.addLast(callback);
            this.callbacks.put(s, callback_list);
        }
        else
        {
            callback_list.addLast(callback);
        }
        OtpOutputStream subscribe = new OtpOutputStream();
        subscribe.write(OtpExternal.versionTag);
        final OtpErlangObject[] tuple = {new OtpErlangAtom("subscribe"),
                                         new OtpErlangString(pattern)};
        subscribe.write_any(new OtpErlangTuple(tuple));
        send(subscribe);
    }
public void subscribe ( final String pattern , final FunctionInterface9 callback ) { final String s = this . prefix + pattern ; LinkedList < FunctionInterface9 > callback_list = this . callbacks . get ( s ) ; if ( callback_list == null ) { callback_list = new LinkedList < FunctionInterface9 > ( ) ; callback_list . addLast ( callback ) ; this . callbacks . put ( s , callback_list ) ; } else { callback_list . addLast ( callback ) ; } OtpOutputStream subscribe = new OtpOutputStream ( ) ; subscribe . write ( OtpExternal . versionTag ) ; final OtpErlangObject [ ] tuple = { new OtpErlangAtom ( "subscribe" ) , new OtpErlangString ( pattern ) } ; subscribe . write_any ( new OtpErlangTuple ( tuple ) ) ; send ( subscribe ) ; }
Subscribes an object method to a service name pattern.

@param  pattern     the service name pattern
@param  callback    method reference for callback (Java 8 or higher)
Subscribes an object method to a service name pattern .