Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include <zmq.hpp>
- #include <zmq.h>
- #include <iostream>
- #include "zhelpers.hpp"
- using namespace std;
- int main(int argc, char *argv[])
- {
- zmq::context_t context(1);
- /*
- std::cout << "Sending message to NM Server…\n" << std::endl; */
- zmq::socket_t subscriber(context, ZMQ_SUB);
- subscriber.connect("tcp://localhost:5557");
- subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0);
- zmq::socket_t sender(context, ZMQ_PUSH);
- sender.connect("tcp://localhost:5558");
- string firstMessage = "Hola, soy el cliente 1";
- while (1)
- {
- // Wait for next request from client
- std::string string = s_recv(subscriber);
- std::cout << "Received request: " << string << std::endl;
- // Do some 'work'
- // sleep(1);
- // Send reply back to client
- // zmq::message_t message(firstMessage.size() + 1);
- // Cualquiera de los dos se puede
- // memcpy(message.data(), firstMessage.c_str(), firstMessage.size() + 1);
- // s_send(sender, "Hola soy un responder 1");
- // sender.send(message);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment