Qpid получает сообщение по идентификатору корреляции (используя приложение c ++)

Qpid предлагает ответы на полученное сообщение. Для параллельной обработки у нас есть несколько экземпляров приложения, которые прослушивают одну и ту же очередь. Проблема в том, что мне бы хотелось, чтобы точно такой же экземпляр получил ответ. Я считаю, что это можно сделать с помощью идентификаторов корреляции, но я не могу найти пример, как это сделать с помощью Qpid.

Я искал в Интернете и нашел обсуждение с 2009 года (http://qpid.2158936.n2.nabble.com/get-message-by-correlationId-td3440876.html) где они намеревались добавить селекторы в ближайшее время. Это, вероятно, связанный билет (https://issues.apache.org/jira/browse/QPID-4558). Завершена подзадача «Начальная реализация селектора», поэтому я верю, что это реализовано.

Я искал документацию по API и нашел методы getCorrelationId () и setCorrelationId (), но не могу найти пример того, как отфильтровать сообщения из очереди.

Благодарю.