Examples of de.zib.scalaris.PubSub.subscribe()

de.zib.scalaris.PubSub.subscribe()
Subscribes a url to a topic. @param topic the topic to subscribe the url to @param url the url of the subscriber (this is where the events are send to) @throws ConnectionException if the connection is not active or a communication error occurs or an exit signal was received or the remote node sends a message containing an invalid cookie @throws TimeoutException if a timeout occurred while trying to write the value @throws AbortException if the commit of the subscribe failed @throws UnknownException if any other error occurs

        try {
            System.out.println("  creating object...");
            final PubSub sc = new PubSub();
            System.out
                    .println("    `void subscribe(OtpErlangString, OtpErlangString)`...");
            sc.subscribe(otpTopic, otpURL);
            System.out.println("      subscribe(" + otpTopic.stringValue()
                    + ", " + otpURL.stringValue() + ") succeeded");
        } catch (final ConnectionException e) {
            System.out.println("      subscribe(" + otpTopic.stringValue()
                    + ", " + otpURL.stringValue() + ") failed: "

View Full Code Here


        try {
            System.out.println("  creating object...");
            final PubSub sc = new PubSub();
            System.out.println("    `void subscribe(String, String)`...");
            sc.subscribe(topic, URL);
            System.out.println("      subscribe(" + topic + ", " + URL
                    + ") succeeded");
        } catch (final ConnectionException e) {
            System.out.println("      subscribe(" + topic + ", " + URL
                    + ") failed: " + e.getMessage());

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.