Я пытаюсь получить сообщения из очереди на основе идентификатора корреляции, используя метод session.createConsumer(queue,messageSelector)
, но он возвращает null
.
Ниже приведен полный синтаксис
MessageConsumer queueConsumer = queueSession.createConsumer(destinationQueue, "CorrID='"+correlationID+"'");
Может кто-нибудь подсказать, в чем может быть причина?Заранее спасибо