1 #include "Subscriber.h"
10 addr_sub = strdup(
">tcp://localhost:5001");
13 Subscriber::~Subscriber()
21 sub = zsock_new_sub(addr_sub,
"");
22 printf(
"Subscriber is connected to %s\n", &addr_sub[1]);
32 zmsg_t* msg = zmsg_recv(sub);
34 char* sub_str = zmsg_popstr(msg);
36 char* clstr = zmsg_popstr(msg);
37 char* jsn = zmsg_popstr(msg);
48 return pair<string, string>(cluster, json);
void Set_Addr(char *addr)
pair< string, string > Get_Cluster_Json()