Closed vegapit closed 4 years ago
Having a look at libzmq
source, it seems this assert in fq.cpp
is triggered:
// Check the atomicity of the message.
// If we've already received the first part of the message
// we should get the remaining parts without blocking.
zmq_assert (!_more);
Are you using multipart messages in combination with ZMQ_CONFLATE
? If so, this is noted as not supported in zmq_setsockopt(3)
:
Does not support multi-part messages, in particular, only one part of it is kept in the socket internal queue.
However, I would have not guessed that "not supported" means "crashing on an assertion" :man_shrugging:.
I've prepared a small test case which shows that ZMQ_CONFLATE
on the receiver side appears to work, at least when used with single-part messages on a PUSH
/PULL
socket pair. I'll reference this issue when I send out the PR for that test, so it should show up in this thread soonish™.
I will need to read the doc a little longer next time =:]
Hello,
I am running into issues when using a Subscriber with the Conflate setting. Here is below the code for my Subscriber struct.
It works like a charm when Conflate is not turned on, but as I enable it, I am getting the following error after a few messages:
Any ideas on what the problem could be?