# JMS input getting an error JMS Consumer Died **URL:** \ **Category:** Logstash\ **Created:** [May 20, 2019, 5:15pm UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877 "2019-05-20T17:15:36Z")\ **Posts on this page:** 10\ **Page:** 1
**Author:** ![bigster](https://avatars.discourse-cdn.com/v4/letter/b/8e7dd6/32.png) [@bigster](https://discuss.elastic.co/u/bigster)\ **Post date:** [May 20, 2019, 5:15pm UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/1 "2019-05-20T17:15:36Z")
Hi all, I've got a JMS input in my logstash config getting messages from a IBM MQ and i'm getting this error: JMS Consumer died {:exception=\>com.ibm.msg.client.jms.DetailedMessageEOFException: JMSWMQ2002: Failed to get a message from destination 'XXXX' After digging a bit i find the mqjms.log with this entry: Caused by [1] --\> Message : com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed with compcode '2' ('MQCC\_FAILED') reason '2009' ('MQRC\_CONNECTION\_BROKEN'). I've question our infrastructure guys and none of our FW or something like this interrupted the consuming, but we keep getting this error. The strange thing is that the process runs, but occasionally keeps getting this error. Anyone passed by this kind of error? Cheers, Nuno Ferreira ---
**Author:** ![bigster](https://avatars.discourse-cdn.com/v4/letter/b/8e7dd6/32.png) [@bigster](https://discuss.elastic.co/u/bigster)\ **Post date:** [May 22, 2019, 10:33am UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/2 "2019-05-22T10:33:06Z")
No one passes this kind of error? Here are more details: [2019-05-22T11:31:53,591][WARN][logstash.inputs.jms] JMS Consumer died {:exception=\>com.ibm.msg.client.jms.DetailedMessageEOFException: JMSWMQ2002: Failed to get a message from destination 'Q.LOG.MESSAGE'. IBM MQ classes for JMS attempted to perform an MQGET; however IBM MQ reported an error. Use the linked exception to determine the cause of this error., :backtrace=\>["com.ibm.msg.client.wmq.common.internal.Reason.reasonToException(com/ibm/msg/client/wmq/common/internal/Reason.java:539)", "com.ibm.msg.client.wmq.common.internal.Reason.createException(com/ibm/msg/client/wmq/common/internal/Reason.java:215)", "com.ibm.msg.client.wmq.internal.WMQMessageConsumer.checkJmqiCallSuccess(com/ibm/msg/client/wmq/internal/WMQMessageConsumer.java:266)", "com.ibm.msg.client.wmq.internal.WMQMessageConsumer.checkJmqiCallSuccess(com/ibm/msg/client/wmq/internal/WMQMessageConsumer.java:156)", "com.ibm.msg.client.wmq.internal.WMQConsumerShadow.getMsg(com/ibm/msg/client/wmq/internal/WMQConsumerShadow.java:1848)", "com.ibm.msg.client.wmq.internal.WMQSyncConsumerShadow.receiveInternal(com/ibm/msg/client/wmq/internal/WMQSyncConsumerShadow.java:231)", "com.ibm.msg.client.wmq.internal.WMQConsumerShadow.receive(com/ibm/msg/client/wmq/internal/WMQConsumerShadow.java:1480)", "com.ibm.msg.client.wmq.internal.WMQMessageConsumer.receive(com/ibm/msg/client/wmq/internal/WMQMessageConsumer.java:670)", "com.ibm.msg.client.jms.internal.JmsMessageConsumerImpl.receiveInboundMessage(com/ibm/msg/client/jms/internal/JmsMessageConsumerImpl.java:1074)", "com.ibm.msg.client.jms.internal.JmsMessageConsumerImpl.receive(com/ibm/msg/client/jms/internal/JmsMessageConsumerImpl.java:692)", "com.ibm.mq.jms.MQMessageConsumer.receive(com/ibm/mq/jms/MQMessageConsumer.java:209)", "java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:498)", "org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:455)", "org.jruby.javasupport.JavaMethod.invokeDirect(org/jruby/javasupport/JavaMethod.java:316)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.message\_consumer.get(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/message\_consumer.rb:33)", "org.jruby.RubyMethod.call(org/jruby/RubyMethod.java:117)", "org.jruby.RubyMethod$INVOKER$i$call.call(org/jruby/RubyMethod$INVOKER$i$call.gen)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.mq\_workaround.get(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/mq\_workaround.rb:42)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.message\_consumer.each(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/message\_consumer.rb:69)", "org.jruby.RubyMethod.call(org/jruby/RubyMethod.java:117)", "org.jruby.RubyMethod$INVOKER$i$call.call(org/jruby/RubyMethod$INVOKER$i$call.gen)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.mq\_workaround.each(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/mq\_workaround.rb:36)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.session.consume(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/session.rb:402)", "org.jruby.RubyMethod.call(org/jruby/RubyMethod.java:117)", "org.jruby.RubyMethod$INVOKER$i$call.call(org/jruby/RubyMethod$INVOKER$i$call.gen)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.mq\_workaround.consume(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/mq\_workaround.rb:6)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.logstash\_minus\_input\_minus\_jms\_minus\_3\_dot\_0\_dot\_5\_minus\_java.lib.logstash.inputs.jms.run\_consumer(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/logstash-input-jms-3.0.5-java/lib/logstash/inputs/jms.rb:189)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:286)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:266)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.connection.session(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/connection.rb:258)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.connection.session(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/connection.rb:71)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:286)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:266)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.connection.start(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/connection.rb:53)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.jruby\_minus\_jms\_minus\_1\_dot\_3\_dot\_0\_minus\_java.lib.jms.connection.session(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/jruby-jms-1.3.0-java/lib/jms/connection.rb:70)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.logstash\_minus\_input\_minus\_jms\_minus\_3\_dot\_0\_dot\_5\_minus\_java.lib.logstash.inputs.jms.run\_consumer(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/logstash-input-jms-3.0.5-java/lib/logstash/inputs/jms.rb:186)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.logstash\_minus\_input\_minus\_jms\_minus\_3\_dot\_0\_dot\_5\_minus\_java.lib.logstash.inputs.jms.RUBY$method$run\_consumer$0$ **VARARGS** (D\_3a\_/elk/logstash\_minus\_6\_dot\_7\_dot\_1/vendor/bundle/jruby/$2\_dot\_5\_dot\_0/gems/logstash\_minus\_input\_minus\_jms\_minus\_3\_dot\_0\_dot\_5\_minus\_java/lib/logstash/inputs/D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/logstash-input-jms-3.0.5-java/lib/logstash/inputs/jms.rb)", "D\_3a\_.elk.logstash\_minus\_6\_dot\_7\_dot\_1.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.logstash\_minus\_input\_minus\_jms\_minus\_3\_dot\_0\_dot\_5\_minus\_java.lib.logstash.inputs.jms.run(D:/elk/logstash-6.7.1/vendor/bundle/jruby/2.5.0/gems/logstash-input-jms-3.0.5-java/lib/logstash/inputs/jms.rb:257)", ---
**Author:** ![nugusbayevkk](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/nugusbayevkk/32/126683_2.png) [@nugusbayevkk](https://discuss.elastic.co/u/nugusbayevkk)\ **Post date:** [May 22, 2019, 10:59am UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/3 "2019-05-22T10:59:15Z")
hi @bigster here, you can find connection example to websphere mq: > but currently, input jms plugin haven't opportunity to reconnect: > ---
**Author:** ![bigster](https://avatars.discourse-cdn.com/v4/letter/b/8e7dd6/32.png) [@bigster](https://discuss.elastic.co/u/bigster)\ **Post date:** [May 22, 2019, 1:26pm UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/4 "2019-05-22T13:26:31Z")
Hi, I've got that post already, my configuration its OK. I think this is not a connect issue but a load issue. I've made some tests and it seems that when i get a real large message in the MQ Manager the JMS input hangs with the error above. I process a few messages and everything works great until the next large message. The size of the message seems to be 5MB of size. Any ideas about this behavior? I'm wrong? How can i check if this is the issue i'm experiencing? Cheers, ---
**Author:** ![nugusbayevkk](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/nugusbayevkk/32/126683_2.png) [@nugusbayevkk](https://discuss.elastic.co/u/nugusbayevkk)\ **Post date:** [May 22, 2019, 1:32pm UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/5 "2019-05-22T13:32:58Z")
@bigster, what about channel throughput?(I don't remember a name of this parameter) ---
**Author:** ![bigster](https://avatars.discourse-cdn.com/v4/letter/b/8e7dd6/32.png) [@bigster](https://discuss.elastic.co/u/bigster)\ **Post date:** [May 22, 2019, 1:46pm UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/6 "2019-05-22T13:46:54Z")
Hi don't know this parameter. Where can i find that parameter to test the behavior? ---
**Author:** ![nugusbayevkk](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/nugusbayevkk/32/126683_2.png) [@nugusbayevkk](https://discuss.elastic.co/u/nugusbayevkk)\ **Post date:** [May 22, 2019, 1:49pm UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/7 "2019-05-22T13:49:56Z")
[https://www.ibm.com/support/knowledgecenter/en/SSFKSJ\_9.0.0/com.ibm.mq.explorer.doc/e\_properties\_channels.htm](https://www.ibm.com/support/knowledgecenter/en/SSFKSJ_9.0.0/com.ibm.mq.explorer.doc/e_properties_channels.htm) Maximum message length of channel by default, it's equal to 4mb. So, via Mq explorer or command line you need increase this parameter. ---
**Author:** ![bigster](https://avatars.discourse-cdn.com/v4/letter/b/8e7dd6/32.png) [@bigster](https://discuss.elastic.co/u/bigster)\ **Post date:** [May 23, 2019, 11:05am UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/8 "2019-05-23T11:05:22Z")
Hi, This was the problem, i was connecting to a channel that has the max size inferior of the queue, and que MQ drops the connection. Created a new channel with the max with the same size of the max of the queue and everything works. Cheers. ---
**Author:** ![nugusbayevkk](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/nugusbayevkk/32/126683_2.png) [@nugusbayevkk](https://discuss.elastic.co/u/nugusbayevkk)\ **Post date:** [May 23, 2019, 11:26am UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/9 "2019-05-23T11:26:03Z")
Great! You are welcome! ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [June 20, 2019, 11:26am UTC](https://discuss.elastic.co/t/jms-input-getting-an-error-jms-consumer-died/181877/10 "2019-06-20T11:26:05Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.