Is there any possible concurrent access to that message?
On 28 July 2010 17:34, lilyevsky <lilyev...@mooncapital.com> wrote:
>
> I have seen on this forum other users complain about javax.jms.JMSException:
> java.io.EOFException happening in the receiver, but it seems that my case is
> in the different context.
>
> I am using ActiveMQ 5.3.2.
>
> Please look at my exception log below. The exception happens when I attempt
> an innocent check msg.propertyExists(<some name>). It is probably caused by
> the fact that in the message printout it says "properties = null". How come
> it is null? I own both sender and receiver, and all messages that I send
> have some properties. So it does look like some corrupt message, unless it
> is some sort of internal ActiveMQ tracing message (but why is it delivered
> to my consumer?).
> Also, I have a selector set on the consumer, so if a message does not have
> properties at all, it would not come. Which means it could get corrupt on
> the client side.
>
> Currently I am catching this and ignore, but I am not sure whether some
> essential messages are lost this way.
>
> I tried to set wireFormat.maxInactivityDuration=0 on both sender and
> receiver, it does not help.
>
> What is the mystery?
>
> ====================================================================
>
> [2010-07-28 11:34:08.516] ERROR Thread-7
> com.moon.data.rtfeed.client.ClientSubscription Problem
> reading message ActiveMQMapMessage {commandId = 1992420, responseRequired =
> true, messageId =
> ID:mcny9.mooncapital.corp-39424-1280328991613-2:0:2:1:1984887,
> originalDestination = null, originalTransactionId = null, producerId =
> ID:mcny9.mooncapital.corp-39424-1280328991613-2:0:2:1, destination =
> topic://MKTDATA, transactionId = null, expiration = 0, timestamp =
> 1280331248515, arrival = 0, brokerInTime = 1280331248515, brokerOutTime =
> 1280331248515, 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.byteseque...@70e14f34, marshalledProperties =
> org.apache.activemq.util.byteseque...@581718d1, 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:478)
> at
> com.moon.data.rtfeed.jms.JmsReceiver$MessageDispatcher.run(JmsReceiver.java:69)
> 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
>
> --
> View this message in context:
> http://old.nabble.com/Another-case-of-javax.jms.JMSException%3A-java.io.EOFException-tp29288496p29288496.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
