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);
 			}
 		}