From 97b77a911fe27bc922c77e653638602fb570b251 Mon Sep 17 00:00:00 2001 From: Radek Davidek Date: Tue, 17 Mar 2026 16:08:09 +0100 Subject: [PATCH] fixed JMS Consumer --- .../test/harness/connectors/messaging/IbmMqConnector.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java b/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java index de4d0d8..836bcfd 100644 --- a/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java +++ b/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java @@ -210,8 +210,7 @@ public class IbmMqConnector implements Connector { long timeoutMs = timeout.toMillis(); javax.jms.Queue queue = getQueue(queueName); - MessageConsumer consumer = (MessageConsumer) (messageSelector == null || messageSelector.isBlank() - ? jmsContext.createConsumer(queue) + JMSConsumer consumer = (messageSelector == null || messageSelector.isBlank() ? jmsContext.createConsumer(queue) : jmsContext.createConsumer(queue, messageSelector)); AtomicBoolean messageFound = new AtomicBoolean(false); @@ -248,7 +247,7 @@ public class IbmMqConnector implements Connector { } finally { try { consumer.close(); - } catch (JMSException e) { + } catch (JMSRuntimeException e) { LOG.warn("Failed to close consumer", e); } }