activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lilyevsky <lilyev...@mooncapital.com>
Subject Another case of javax.jms.JMSException: java.io.EOFException
Date Wed, 28 Jul 2010 16:34:32 GMT

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.ByteSequence@70e14f34, marshalledProperties =
org.apache.activemq.util.ByteSequence@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.


Mime
View raw message