ZMQ_Send.java

Go to the documentation of this file.

package grl.flatBufferTesting;

import java.util.concurrent.TimeUnit;
import org.zeromq.ZMQ;
 
public class ZMQ_Send {
    static final String TOPIC = "topic1";
    static final int NUM_MSG = 10;
    public static void main(String[] args) throws Exception {
        long bTime = System.currentTimeMillis();
        
        // Prepare our context and publisher
        ZMQ.Context context = ZMQ.context(1);
        ZMQ.Socket publisher = context.socket(ZMQ.DEALER);
        publisher.bind("tcp://127.0.0.1:5563");
        publisher.setHWM(1000000);
        publisher.setSndHWM(1000000);
        
        int c = 0;
        while (c < NUM_MSG) {
            byte [] msg = {0,1,2,3,4,(byte) c};
            c++;
            publisher.send(msg,0);
            System.out.println(msg);
        }
        
        long secs = TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis() - bTime);
        System.out.println("Wuclient done at "+c + " in "+secs + " seconds");
        Thread.sleep(2000);
        publisher.close();
        context.term();
        System.exit(1);
    }
}