package org.sim0mq.demo;
   
   import org.sim0mq.Sim0MQException;
   import org.sim0mq.message.MessageStatus;
   import org.sim0mq.message.SimulationMessage;
   import org.zeromq.ZMQ;
   
   /**
    * Client example for JeroMQ / ZeroMQ.
   * <p>
   * (c) copyright 2002-2016 <a href="http://www.simulation.tudelft.nl">Delft University of Technology</a>. <br>
   * BSD-style license. See <a href="http://www.simulation.tudelft.nl/dsol/3.0/license.html">DSOL License</a>. <br>
   * @author <a href="http://www.tbm.tudelft.nl/averbraeck">Alexander Verbraeck</a>
   * @version Oct 21, 2016
   */
  public class Client
  {
      /**
       * @param args command line arguments
       * @throws Sim0MQException on error
       */
      public static void main(String[] args) throws Sim0MQException
      {
          ZMQ.Context context = ZMQ.context(1);
  
          // Socket to talk to server
          System.out.println("Connecting to server...");
  
          ZMQ.Socket requester = context.socket(ZMQ.REQ);
          requester.connect("tcp://localhost:5556");
          // requester.connect("tcp://131.180.98.169:5556");
          // requester.connect("tcp://130.161.3.179:5556");
  
          // send a reply
          Object[] request = new Object[] { "test message", new Double(14.2), new Float(-28.4), new Short((short) 10) };
          requester.send(SimulationMessage.encodeUTF8("IDVV14.2", "MC.1", "MM1.4", "TEST.2", 1201L, MessageStatus.NEW, request), 0);
  
          byte[] reply = requester.recv(0);
          Object[] replyMessage = SimulationMessage.decode(reply);
          System.out.println("Received\n" + SimulationMessage.print(replyMessage));
  
          requester.close();
          context.term();
      }
  
  }