import org.zeromq.ZMQ;

//
//  Reading from multiple sockets in Java
//  This version uses ZMQ.Poller
//
//  Nicola Peduzzi <thenikso@gmail.com>
//
public class mspoller {

	public static void main(String[] args) {
		ZMQ.Context context = ZMQ.context(1);

		// Connect to task ventilator
		ZMQ.Socket receiver = context.socket(ZMQ.PULL);
		receiver.connect("tcp://localhost:5557");

		//  Connect to weather server
		ZMQ.Socket subscriber = context.socket(ZMQ.SUB);
		subscriber.connect("tcp://localhost:5556");
		subscriber.subscribe("10001 ".getBytes());

		//  Initialize poll set
		ZMQ.Poller items = context.poller(2);
		items.register(receiver, 0);
		items.register(subscriber, 0);

		//  Process messages from both sockets
		while (true) {
			byte[] message;
			items.poll();
			if (items.pollin(0)) {
				message = receiver.recv(0);
				//  Process task
			}
			if (items.pollin(1)) {
				message = subscriber.recv(0);
				//  Process weather update
			}
		}
	}
}