hlit-mon  0.5.2
 All Classes Functions Groups Pages
Subscriber.cpp
1 #include "Subscriber.h"
2 
4 {
5  addr_sub = addr;
6 }
7 
9 {
10  addr_sub = strdup(">tcp://localhost:5001");
11 }
12 
13 Subscriber::~Subscriber()
14 {
15  zsock_destroy(&sub);
16  free(addr_sub);
17 }
18 
20 {
21  sub = zsock_new_sub(addr_sub, "");
22  printf("Subscriber is connected to %s\n", &addr_sub[1]);
23 }
24 
25 void Subscriber::Set_Addr(char* addr)
26 {
27  addr_sub = addr;
28 }
29 
31 {
32  zmsg_t* msg = zmsg_recv(sub);
33  if (msg) {
34  char* sub_str = zmsg_popstr(msg);
35  free(sub_str);
36  char* clstr = zmsg_popstr(msg);
37  char* jsn = zmsg_popstr(msg);
38  cluster = clstr;
39  json = jsn;
40  free(clstr);
41  free(jsn);
42  }
43  zmsg_destroy(&msg);
44 }
45 
46 pair<string, string> Subscriber::Get_Cluster_Json()
47 {
48  return pair<string, string>(cluster, json);
49 }
void Set_Addr(char *addr)
Definition: Subscriber.cpp:25
void Recv_Message()
Definition: Subscriber.cpp:30
pair< string, string > Get_Cluster_Json()
Definition: Subscriber.cpp:46
void Connect()
Definition: Subscriber.cpp:19