kamma/harness
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed JMS Consumer

Browse Source
This commit is contained in:
Radek Davidek 2026-03-17 16:08:09 +01:00
parent 0833bcff06
commit 97b77a911f
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java
View File

@ -210,8 +210,7 @@ public class IbmMqConnector implements Connector {
long timeoutMs = timeout.toMillis(); long timeoutMs = timeout.toMillis();
javax.jms.Queue queue = getQueue(queueName); javax.jms.Queue queue = getQueue(queueName);
MessageConsumer consumer = (MessageConsumer) (messageSelector == null || messageSelector.isBlank() JMSConsumer consumer = (messageSelector == null || messageSelector.isBlank() ? jmsContext.createConsumer(queue)
? jmsContext.createConsumer(queue)
: jmsContext.createConsumer(queue, messageSelector)); : jmsContext.createConsumer(queue, messageSelector));
AtomicBoolean messageFound = new AtomicBoolean(false); AtomicBoolean messageFound = new AtomicBoolean(false);
@ -248,7 +247,7 @@ public class IbmMqConnector implements Connector {
} finally { } finally {
try { try {
consumer.close(); consumer.close();
} catch (JMSException e) { } catch (JMSRuntimeException e) {
LOG.warn("Failed to close consumer", e); LOG.warn("Failed to close consumer", e);
} }
} }