Minor changes

1 files changed, 10 insertions, 7 deletions

diff --git a/src/client.c b/src/client.c
index 35a62c6..cd01232 100644
--- a/src/client.c
+++ b/src/client.c
@@ -15,10 +15,11 @@ int main (int argc, char *argv [])
     exit(1);
   }
 
+  //----- Arguments
   char *ip=argv[1];
   int port=atoi(argv[2]);
 
-  //  Socket to talk to server
+  //----- Init ZMQ
   void *context = zmq_ctx_new ();
   void *subscriber = zmq_socket (context, ZMQ_SUB);
   char bindto[30];
@@ -31,12 +32,14 @@ int main (int argc, char *argv [])
   rc = zmq_setsockopt (subscriber, ZMQ_SUBSCRIBE,
                         ZMQ_TOKEN, strlen(ZMQ_TOKEN));
 
-
-
-  char buffer[10];
-  zmq_recv (subscriber, buffer, 10, 0);
-  printf("Received!");
-
+  //----- Listen
+  char buffer[ZMQ_MSG_SIZE];
+  int size;
+  while(1){
+    size=zmq_recv (subscriber, buffer, ZMQ_MSG_SIZE-1, 0);
+    buffer[size < ZMQ_MSG_SIZE ? size : ZMQ_MSG_SIZE - 1] = '\0';
+    printf("Received: %s\n",buffer);
+  }