Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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

...