zeromq/libzmq

import org.json.JSONObject;
import org.zeromq.SocketType;
import org.zeromq.ZContext;
import org.zeromq.ZMQ;
import org.zeromq.ZMQException;
import java.math.BigDecimal;
import java.util.Arrays;

public class RatePublisher {
    private static final ZContext context = new ZContext();
    private static final ZMQ.Socket publisher = context.createSocket(SocketType.PUB);
    private static String zmqAddress = "tcp://localhost:5563";

   static {
        publisher.bind(zmqAddress);
    }

 public static void publish(String name, String ident, BigDecimal rate, BigDecimal changePercentage) throws InterruptedException {
        try {
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("name", name);
            jsonObject.put("ident", ident);
            jsonObject.put("rate", rate);
            jsonObject.put("changed_percentage", changePercentage);
           publisher.sendMore("rate");
           publisher.send(jsonObject.toString());
        } catch (ZMQException e) {
            e.printStackTrace();
            throw new InterruptedException();
        }
    }

    public static void close() throws InterruptedException {
        try {
            context.destroy();
        } catch (Exception e) {
            throw new InterruptedException();
        }
    }
}

public class A 
{   
    public static void main(String[] args)
    {
        int i = 100;
        while(i>0) {
           RatePublisher.publish("test", pair, rate, changePercentage);
           i--;
        }
    }
}

public class B 
{   
    public static void main(String[] args)
    {
        int i = 100;
        while(i>0) {
           RatePublisher.publish("test", pair, rate, changePercentage);
           i--;
        }
    }
}

public class C 
{   
    public static void main(String[] args)
    {
        int i = 100;
        while(i>0) {
           RatePublisher.publish("test", pair, rate, changePercentage);
           i--;
        }
    }
}

public class D
{   
    public static void main(String[] args)
    {
        int i = 100;
        while(i>0) {
           RatePublisher.publish("test", pair, rate, changePercentage);
           i--;
        }
    }
}