I am using ZMQ.jl for a PUB-SUB socket operation. Occasionally, the operation gets into a situation where the subscriber becomes slow and as a result the messages from the publisher accumulates in the subscriber’s buffer. Ideally, I would like to discard old messages so that the subscriber only gets the last message sent.
After some googling, there is an option called CONFLATE, but I do not find it in ZMQ.jl. I do have the latest ZMQ.jl (v1.2.2).
Does anyone know whether this option is implemented and if so how I can use this option?