Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include <zmq.h>
- #include <string.h>
- #include <stdio.h>
- #include <unistd.h>
- int main (int argc, char * argv[])
- {
- if(argc != 2){
- printf("Not enogh arguments\n");
- return -1;
- }
- printf ("Connecting to hello world server...\n");
- void *context = zmq_ctx_new ();
- void *requester = zmq_socket (context, ZMQ_REQ);
- zmq_setsockopt (requester, ZMQ_IDENTITY, "CLIENT", 6);
- zmq_connect (requester, "tcp://localhost:5555");
- int request_nbr;
- for (request_nbr = 0; request_nbr != 10; request_nbr++) {
- char buffer [255];
- printf ("Sending Hello %d...\n", request_nbr);
- sleep(1);
- //zmq_send (requester, "CLIENT", strlen("CLIENT")+ 1, ZMQ_SNDMORE);
- zmq_send (requester, "", strlen("")+ 1, ZMQ_SNDMORE);
- zmq_send (requester, argv[1], strlen(argv[1])+ 1, 0);
- printf("Hello was send\n");
- //zmq_recv (requester, buffer, 255, 0);
- //printf ("Received: %s %d\n", buffer, request_nbr);
- //printf ("%s\n",buffer);
- }
- zmq_close (requester);
- zmq_ctx_destroy (context);
- return 0;
- }
Advertisement
Add Comment
Please, Sign In to add comment