import org.zeromq.ZMQ;
//
// Reading from multiple sockets in Java
// This version uses ZMQ.Poller
//
// Nicola Peduzzi <moc.liamg|oskineht#moc.liamg|oskineht>
//
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, ZMQ.Poller.POLLIN);
items.register(subscriber, ZMQ.Poller.POLLIN);
// 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
}
}
}
}