THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
#include "qpid/client/QueueOptions.h" QueueOptions qo; qo.setOrdering(LVQ); session.queueDeclare(arg::queue=queue, arg::arguments=qo); ... add more details.. string key; qo.getLVQKey(key); .... for each message, set the into application headers before transfer session.queueDeclare(arg::queue=queue, arg::arguments=qo);message.getHeaders().setString(key,"RHT"); |
Setting additional behaviors - Optimistic Consume
...