ZMQ Router Sample

zmqrouter.cpp

/*
  ./zmqrouter
  identity: SinkFrame
  msg: Connect
  identity: SinkFrame
  msg: Connect
  identity: SinkFrame
  msg: Connect
*/

#include "streamproc/zhelpers.hpp"

int main() {
  zmq::context_t context(1);
  zmq::socket_t router(context, ZMQ_ROUTER);
  router.bind("tcp://*:5555");

  while(1) {

    std::string identity = s_recv(router);
    std::string msg = s_recv(router);

    std::cout << "identity: " << identity << "\n";
    std::cout << "msg: " << msg << "\n";

    s_sendmore(router, identity);
    s_sendmore(router, std::string("OK"));

    if (msg == "Q")
      break;
  }

  return 0;

}