Multiple socket poller in Java

import org.zeromq.ZMQ;

//
// Reading from multiple sockets in Java
// This version uses ZMQ.Poller
//

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 = new ZMQ.Poller (2);
items.register(receiver, ZMQ.Poller.POLLIN);
items.register(subscriber, ZMQ.Poller.POLLIN);

// Process messages from both sockets
while (!Thread.currentThread ().isInterrupted ()) {
byte[] message;
items.poll();
if (items.pollin(0)) {
message = receiver.recv(0);
System.out.println("Process task");
}
if (items.pollin(1)) {
message = subscriber.recv(0);
System.out.println("Process weather update");
}
}
receiver.close ();
context.term ();
}
}