content: 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);
      }
  }