AirInvClient.cpp

Go to the documentation of this file.

// //////////////////////////////////////////////////////////////////////
// Import section
// //////////////////////////////////////////////////////////////////////
// STL
#include <string>
#include <iostream>
// ZeroMQ
#include <zmq.hpp>
 
// ////////////////// M A I N /////////////////////
int main (int argc, char* argv[]) {
  // Prepare our context and socket
  zmq::context_t context (1);
  zmq::socket_t socket (context, ZMQ_REQ);
 
  std::cout << "Connecting to hello world server…" << std::endl;
  socket.connect ("tcp://localhost:5555");
 
  // Do 10 requests, waiting each time for a response
  for (int request_nbr = 0; request_nbr != 10; request_nbr++) {
    zmq::message_t request (6);
    memcpy ((void *) request.data (), "Hello", 5);
    std::cout << "Sending Hello " << request_nbr << "…" << std::endl;
 
    zmq::send_flags flags = zmq::send_flags::none;
    const zmq::send_result_t rcs = socket.send (request, flags);
 
    // DEBUG
    if (rcs.has_value()) {
      const unsigned int rcs_val = rcs.value();
      std::cout << "Result of sending payload: " << rcs_val << std::endl;
    }
 
    // Get the reply.
    zmq::message_t reply;
    zmq::recv_result_t rcr = socket.recv (reply);
 
    // DEBUG
    if (rcr.has_value()) {
      const unsigned int rcr_val = rcr.value();
      std::cout << "Receive status: " << rcr_val << std::endl;
    }
 
    //
    std::cout << "Received World " << request_nbr << std::endl;
  }
  return 0;
}