ctp3-mon  0.3.0
 All Classes Functions Variables Pages
ctp3-zmq-sub.cpp
1 #include <czmq.h>
2 #include <iostream>
3 #include <map>
4 #include <spdlog/fmt/ostr.h>
5 #include <spdlog/spdlog.h>
6 #include <utility>
7 using namespace std;
8 
9 shared_ptr<spdlog::logger> logger = nullptr;
10 
11 int main(int argc, char ** /*argv*/) {
12 
13  // creating logger
14  auto console = spdlog::stdout_logger_mt("console");
15  logger = spdlog::get("console");
16  if (argc > 1)
17  spdlog::set_level(spdlog::level::trace);
18 
19  zsock_t *sub = zsock_new_sub(">tcp://localhost:5001", "");
20  assert(sub);
21 
22  while (!zsys_interrupted) {
23  zmsg_t *msg_in = zmsg_recv(sub);
24  if (!msg_in)
25  break;
26  zmsg_print(msg_in);
27  zmsg_destroy(&msg_in);
28  }
29  zsock_destroy(&sub);
30 
31  // cleaning spdlog
32  spdlog::drop_all();
33 
34  return 0;
35 }