sriram23kmm commented on issue #25849:
URL: https://github.com/apache/beam/issues/25849#issuecomment-1482723374

   Getting **Error closing Connection** with jmsIO.read with IBM MQ as jms Queqe
   
   **com.ibm.msg.client.jms.DetailedIllegalStateException: JMSCC0008: This 
connection is closed.
   An application called a method that must not be used after the connection is 
closed.
   Ensure that the connection is not closed before calling the method.**
   
   
   ```
        at 
jdk.internal.reflect.GeneratedConstructorAccessor97.newInstance(Unknown Source)
        at 
java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at 
java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
        at 
com.ibm.msg.client.commonservices.j2se.NLSServices.createException(NLSServices.java:319)
        at 
com.ibm.msg.client.commonservices.nls.NLSServices.createException(NLSServices.java:226)
        at 
com.ibm.msg.client.jms.internal.JmsErrorUtils.createException(JmsErrorUtils.java:126)
        at com.ibm.msg.client.jms.internal.State.checkNotClosed(State.java:142)
        at 
com.ibm.msg.client.jms.internal.JmsConnectionImpl.getMetaData(JmsConnectionImpl.java:950)
        at 
com.ibm.msg.client.jms.internal.JmsConnectionImpl.stop(JmsConnectionImpl.java:1163)
        at com.ibm.mq.jms.MQConnection.stop(MQConnection.java:473)
        **at 
org.apache.beam.sdk.io.jms.JmsIO$UnboundedJmsReader.closeConnection(JmsIO.java:648)
        at 
org.apache.beam.sdk.io.jms.JmsIO$UnboundedJmsReader.lambda$doClose$0(JmsIO.java:635)**
        at 
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        at 
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
        at 
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at 
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:834)
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@beam.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to