Zyre_Listener.C

#include <zyre.h>

// this program starts a zyre node, joins a group,
// receives messages and prints the message frame by frame
int main(int argc, char *argv[])
{
    if (argc < 2)
    {
        printf("Usage: ./zyre_listener <group name>\n");
        return 1;
    }

    char * group_name = argv[1];


    // create a new node
     zyre_t *node = zyre_new("Leader");
     zyre_set_name(node,"Leader");

     //zyre_t *name(zyre_t *self);  // Is it valid ? what it will do

    if (!node)
    {
        return 1;      //  Could not create new node
    }

    // this sends an ENTER message
    zyre_start(node);
    // this sends a JOIN message
    zyre_join(node, group_name);
    // wait for a while
    zclock_sleep(250);
    // print UUID of node

    printf    (" Leader's UUID: %s\n", zyre_uuid(node));
    zsys_info (" Leader node, uuid=%s, name=%s", zyre_uuid (node), zyre_name (node));
    zsys_info ("   ******Leader Listening*****  ");
    zyre_event_t *event = zyre_event_new (node); // needed for event


    while (true)
    {

    zmsg_t * msg = zyre_recv(node);

     if (streq (zyre_event_type (event),"ENTER"))

         {
            // If new peer, say hello to it and wait for it to answer us
               zsys_info ("*[%s] Follower info",zyre_event_type (event));
               zyre_whispers (node,zyre_event_peer_uuid (event), "Hello...Follower one ");

        }


        // loop through the frames in the message
         while(true)
         {


            char * msg_str = zmsg_popstr(msg);
            char * command = zmsg_popstr(msg);

            if (!msg_str)
            {
                break;
            }

            printf("frame: %s\n", msg_str);


            /*if (streq(command,"EXIT")) // what this mean? doubt?

            {

                printf(" ********* \n");
                zyre_whispers (node,zyre_event_peer_uuid (event), "Hello...Follower one ");
            }*/

            // with zmsg_popstr, you own the frame string
            // so you need to free it
            free(msg_str);

         }
            printf("------\n");



        // you own the message with zyre_recv
        // so you need to destroy it
        zmsg_destroy(&msg);
     }
    // this sends a LEAVE message
    zyre_leave(node, group_name);
    // this sends an EXIT message
    zyre_stop(node);
    // wait for node to stop
    zclock_sleep(100);

   // zyre_destroy(&node);
    return 0;
}