gistfile1.txt

#include <zmq.hpp>

int main (int argc, char *argv [])
{
    zmq::context_t context (1);
    zmq::socket_t s (context, ZMQ_XREP);
    s.connect ("tcp://127.0.0.1:11132");

    for (int i = 0; i < 1000; i++)
    {
        zmq::message_t identity;
        s.recv (&identity);
        zmq::message_t body;
        s.recv (&body);

        s.send (identity, ZMQ_SNDMORE);
        s.send (body);
    }

    return 0;
}