Message queue broker in Java

package guide;

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

/**

  • Simple message queuing broker
  • Same as request-reply broker but using QUEUE device.

*/
public class msgqueue
{

public static void main(String[] args)
{
// Prepare our context and sockets
try (ZContext context = new ZContext()) {
// Socket facing clients
Socket frontend = context.createSocket(SocketType.ROUTER);
frontend.bind("tcp://*:5559");

// Socket facing services
Socket backend = context.createSocket(SocketType.DEALER);
backend.bind("tcp://*:5560");

// Start the proxy
ZMQ.proxy(frontend, backend, null);
}
}
}