Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include "stdafx.h"
- #include <iostream>
- #include <stdint.h>
- #include <autolink_zeromq.hpp>
- #include "zmq.hpp"
- using namespace std;
- int _tmain(int argc, _TCHAR* argv[])
- {
- const size_t buffer_size = 1 * 1024 * 1024;
- const uint64_t high_water_mark = 4;
- try
- {
- zmq::context_t c(4);
- zmq::socket_t sock(c, ZMQ_PUB);
- sock.bind("epgm://224.9.8.7:1234");
- sock.setsockopt(ZMQ_HWM, &high_water_mark, sizeof(high_water_mark));
- // NEVER ENDING!
- while (true)
- {
- zmq::message_t* t = new zmq::message_t(buffer_size);
- memset(t->data(), '!', buffer_size);
- if (!sock.send(*t))
- {
- Sleep(1000);
- }
- delete t;
- }
- sock.close();
- }
- catch (zmq::error_t e)
- {
- cerr << e.what();
- }
- return 0;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement