EPGM SUB

gistfile1.txt

#include <zmq.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdint.h>

int main () {
    void *context = zmq_init (1);
    printf("Creating Sockets \n");
    int64_t rate = 1000;
    printf("Connecting Sub \n");
    void *sub = zmq_socket (context, ZMQ_SUB);
    zmq_setsockopt( sub, ZMQ_RATE, &rate, sizeof(rate));
    zmq_setsockopt( sub, ZMQ_SUBSCRIBE, "", 0);
    zmq_connect (sub, "epgm://eth0;239.192.0.1:7601");
    printf("Prep Message \n");
    zmq_msg_t message;
    zmq_msg_init(&message);
    printf("recving \n");
    zmq_recv(sub, &message, 0);
    char *data = zmq_msg_data(&message);
    printf("%s \n", data);
    zmq_term (context);
    return 0;
}