ZeroMQ has an option where the subscribe socket only keeps the last
message. I was wondering if there is a way to specify that.
Something like the following:
using ZMQ
ctx = Context()
s = Socket(ctx, SUB)
ZMQ.subscribe(s)
ZMQ.set_subscribe(ZMQ.CONFLATE, 1) # ERROR: LoadError: UndefVarError:
CONFLATE not defined
ZMQ.connect(s, "tcp://127.0.0.1:5001")
while true
msg = bytestring(ZMQ.recv(s))
println(msg)
end
The C++ analog would go something like this:
zmq::context_t context (1);
zmq::socket_t subscriber (context, ZMQ_SUB);
int conflate = 1;
*subscriber**.setsockopt(ZMQ_CONFLATE, &conflate, sizeof(conflate) );
// need this in julia*
subscriber.connect("tcp://localhost:5556");
subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0);
More generally, how are socket options specified in Julia?
http://api.zeromq.org/4-0:zmq-setsockopt
Thanks.
