[
https://issues.apache.org/jira/browse/AMQ-2860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851565#comment-15851565
]
Scott K Pullano commented on AMQ-2860:
--------------------------------------
Hey everyone this is happening for me and i am on mq client 5.13.2. Below is my
error. I am using apache camel 2.16.2 with mq 5.13.2. This error occurs on the
client side. The broker is using 5.10.0. I tried downgrading my client to
5.10.0 and also got the error so i ruled that out. It also only comes when
under high load. If i load 1000 messages in 10 seconds i get about 20 of these.
Has any seen or fixed this issue? I need a resolution asap.
```
2017-02-02 17:50:54,143] [WARN ] [Camel (camel-1) thread #6 - JmsConsumer
Execution of JMS message listener failed. Caused by:
[org.apache.camel.RuntimeCamelException - javax.jms.JMSException:
java.io.EOFException]
org.apache.camel.RuntimeCamelException: javax.jms.JMSException:
java.io.EOFException
at
org.apache.camel.component.jms.JmsBinding.extractHeadersFromJms(JmsBinding.java:193)
~[camel-jms-2.16.2.jar:2.16.2]
at
org.apache.camel.component.jms.JmsMessage.populateInitialHeaders(JmsMessage.java:244)
~[camel-jms-2.16.2.jar:2.16.2]
at
org.apache.camel.impl.DefaultMessage.createHeaders(DefaultMessage.java:203)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.component.jms.JmsMessage.ensureInitialHeaders(JmsMessage.java:229)
~[camel-jms-2.16.2.jar:2.16.2]
at
org.apache.camel.component.jms.JmsMessage.getHeaders(JmsMessage.java:187)
~[camel-jms-2.16.2.jar:2.16.2]
at
org.apache.camel.impl.DefaultUnitOfWork.<init>(DefaultUnitOfWork.java:91)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.impl.DefaultUnitOfWork.<init>(DefaultUnitOfWork.java:72)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.impl.DefaultUnitOfWorkFactory.createUnitOfWork(DefaultUnitOfWorkFactory.java:34)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.createUnitOfWork(CamelInternalProcessor.java:663)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.before(CamelInternalProcessor.java:631)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.before(CamelInternalProcessor.java:608)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:138)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)
~[camel-core-2.16.2.jar:2.16.2]
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:112)
~[camel-jms-2.16.2.jar:2.16.2]
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:689)
~[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:649)
~[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:619)
~[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:307)
[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:245)
[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1144)
[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1136)
[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1033)
[spring-jms-4.1.9.RELEASE.jar:4.1.9.RELEASE]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_51]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_51]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_51]
Caused by: javax.jms.JMSException: java.io.EOFException
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:72)
~[activemq-client-5.13.2.jar:5.13.2]
at
org.apache.activemq.command.ActiveMQMessage.getPropertyNames(ActiveMQMessage.java:331)
~[activemq-client-5.13.2.jar:5.13.2]
at
org.apache.camel.component.jms.JmsBinding.extractHeadersFromJms(JmsBinding.java:191)
~[camel-jms-2.16.2.jar:2.16.2]
... 25 common frames omitted
Caused by: java.io.EOFException: null
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:340)
~[na:1.8.0_51]
at java.io.DataInputStream.readUTF(DataInputStream.java:589) ~[na:1.8.0_51]
at java.io.DataInputStream.readUTF(DataInputStream.java:564) ~[na:1.8.0_51]
at
org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(MarshallingSupport.java:97)
~[activemq-client-5.13.2.jar:5.13.2]
at
org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(MarshallingSupport.java:78)
~[activemq-client-5.13.2.jar:5.13.2]
at
org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(MarshallingSupport.java:70)
~[activemq-client-5.13.2.jar:5.13.2]
at
org.apache.activemq.command.Message.unmarsallProperties(Message.java:222)
~[activemq-client-5.13.2.jar:5.13.2]
at org.apache.activemq.command.Message.getProperties(Message.java:188)
~[activemq-client-5.13.2.jar:5.13.2]
at
org.apache.activemq.command.ActiveMQMessage.getPropertyNames(ActiveMQMessage.java:316)
~[activemq-client-5.13.2.jar:5.13.2]
... 26 common frames omitted
```
> EOFException and ActiveMQMapMessage with null properties
> --------------------------------------------------------
>
> Key: AMQ-2860
> URL: https://issues.apache.org/jira/browse/AMQ-2860
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: 5.4.1
> Environment: Linux
> Reporter: Leonid Ilyevsky
>
> I am getting an error once in a while (see the log below).
> I have an impression that the EOFException is caused by the fact that the
> message has "properties = null". This looks like corrupt message. My sender
> sends messages of the ActiveMQMapMessage type and they all have some
> properties.
> This happens to a small number of messages (compare to overall traffic), but
> very consistently. I handle the exception, but the information is lost.
> [2010-08-04 00:01:53.810] ERROR Thread-36
> com.moon.data.rtfeed.client.ClientSubscription Problem
> reading message ActiveMQMapMessage {commandId = 2797499, responseRequired =
> true, messageId =
> ID:mcny9.mooncapital.corp-55291-1280869129156-2:1:1:1:2797495,
> originalDestination = null, originalTransactionId = null, producerId =
> ID:mcny9.mooncapital.corp-55291-1280869129156-2:1:1:1, destination =
> topic://MKTDATA, transactionId = null, expiration = 0, timestamp =
> 1280894513809, arrival = 0, brokerInTime = 1280894513809, brokerOutTime =
> 1280894513809, correlationId = null, replyTo = null, persistent = true, type
> = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
> null, compressed = false, userID = null, content =
> org.apache.activemq.util.ByteSequence@6f539d49, marshalledProperties =
> org.apache.activemq.util.ByteSequence@5a7b5cb8, dataStructure = null,
> redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
> true, readOnlyBody = true, droppable = false} ActiveMQMapMessage{ theTable =
> {} } javax.jms.JMSException: java.io.EOFException
> at
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
> at
> org.apache.activemq.command.ActiveMQMessage.propertyExists(ActiveMQMessage.java:274)
> at
> com.moon.data.rtfeed.client.ClientSubscription$DataTransformer.onMessage(ClientSubscription.java:463)
> at
> com.moon.data.rtfeed.jms.JmsReceiver$MessageDispatcher.run(JmsReceiver.java:71)
> Caused by: java.io.EOFException: null
> at java.io.DataInputStream.readInt(DataInputStream.java:375)
> at
> org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(MarshallingSupport.java:83)
> at
> org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(MarshallingSupport.java:73)
> at
> org.apache.activemq.command.Message.unmarsallProperties(Message.java:189)
> at org.apache.activemq.command.Message.getProperties(Message.java:162)
> at
> org.apache.activemq.command.ActiveMQMessage.propertyExists(ActiveMQMessage.java:272)
> ... 2 common frames omitted
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
