Setting socket options in ZMQ.jl

[Salman Haider]

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.

[Jeffrey Sarnoff]

How are ZMQ socket options specified in Julia?

 

the attached file may help you