medium_zmq_pub_sub_proxy_java_client.java

package com.zeromq;


import org.zeromq.SocketType;
import org.zeromq.ZContext;
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Socket;


public class Subscriber {

    /**
     * The subscriber thread requests messages starting with
     * C and D, then reads and counts incoming messages.
     * @param args
     */
    public static void main(String[] args){

        System.out.println("Starting Java Subscriber...");

        try (ZContext context = new ZContext()) {

            try (Socket subscriber = context.createSocket(SocketType.SUB)) {
                subscriber.connect("tcp://localhost:6001");

                System.out.println("Subscriber connected to ports 6001");

                subscriber.subscribe("C".getBytes(ZMQ.CHARSET));
                subscriber.subscribe("D".getBytes(ZMQ.CHARSET));

                System.out.println("Listening to topic C, D");

                while (!Thread.currentThread().isInterrupted()) {

                    // Block until a message is received
                    byte[] reply = subscriber.recv(0);

                    System.out.println("Received: [" + new String(reply, ZMQ.CHARSET) + "]");
                }
            }
        }
    }
}