fix: for open connection bug attempt 1

Signed-off-by: Jonathan Hughes <[email protected]>

Author: jhughes24816

pom.xml

@@ -63,7 +63,7 @@
     <dependency>
       <groupId>com.ibm.mq</groupId>
       <artifactId>com.ibm.mq.allclient</artifactId>
-      <version>9.1.5.0</version>
+      <version>9.3.0.0</version>
     </dependency>
 
     <dependency>

src/main/java/com/ibm/eventstreams/connect/mqsource/JMSReader.java

@@ -79,7 +79,7 @@ public class JMSReader {
     private AtomicBoolean closeNow = new AtomicBoolean();           // Whether close has been requested
     private long reconnectDelayMillis = reconnectDelayMillisMin; // Delay between repeated reconnect attempts
 
-    private static long receiveTimeout = 30000L;
+    private static long receiveTimeout = 2000L;
     private static long reconnectDelayMillisMin = 64L;
     private static long reconnectDelayMillisMax = 8192L;
 
@@ -258,10 +258,8 @@ public SourceRecord receive(final boolean wait) {
         SourceRecord sr = null;
         try {
             if (wait) {
-                while (m == null && !closeNow.get()) {
-                    log.debug("Waiting {} ms for message", receiveTimeout);
-                    m = jmsCons.receive(receiveTimeout);
-                }
+                log.debug("Waiting {} ms for message", receiveTimeout);
+                m = jmsCons.receive(receiveTimeout);
 
                 if (m == null) {
                     log.debug("No message received");