nm_sub.cpp

#include <assert.h>

#include <stdio.h>
#include <nanomsg/nn.h>
#include <nanomsg/pubsub.h>
#include <iostream>
#include <sstream>
#include <assert.h>
#include <stdint.h>
#include <zmq.h>
#include <time.h>
#include <ostream>
#include <cstdlib>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>

using namespace std;

int main (const int argc, const char **argv)
{
  int sock = nn_socket (AF_SP, NN_SUB);
  assert (sock >= 0);

  
  if (argc < 2)
    {
      cout << "-USAGE: " << argv[0] << "<uint log print modulo>" << endl;
      abort();
    }
  
  assert (nn_setsockopt (sock, NN_SUB, NN_SUB_SUBSCRIBE, "", 0) >= 0);
  assert (nn_connect (sock, "tcp://localhost:5563") >= 0);

  uint64_t c = 1;

  while (1)
    {
      char *buf = NULL;
      int bytes = nn_recv(sock, buf, NN_MSG, 0);
      
      if (c % atoi(argv[2]) == 0)
        {
          cout << "FOO: bytes=" << bytes << endl ;
          //cout << "RECV " << buf << " with rc="<< bytes << endl;
        }
      ++c;

      nn_freemsg (buf);
    }

  nn_shutdown (sock, 0);
}