Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 94951 invoked from network); 28 Jul 2010 17:21:59 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 28 Jul 2010 17:21:59 -0000 Received: (qmail 4512 invoked by uid 500); 28 Jul 2010 17:21:59 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 4435 invoked by uid 500); 28 Jul 2010 17:21:58 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 4427 invoked by uid 99); 28 Jul 2010 17:21:58 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 28 Jul 2010 17:21:58 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,SPF_HELO_PASS,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates 216.139.236.158 as permitted sender) Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 28 Jul 2010 17:21:52 +0000 Received: from isper.nabble.com ([192.168.236.156]) by kuber.nabble.com with esmtp (Exim 4.63) (envelope-from ) id 1OeAJv-0003Q2-Rn for users@activemq.apache.org; Wed, 28 Jul 2010 10:21:31 -0700 Message-ID: <29288978.post@talk.nabble.com> Date: Wed, 28 Jul 2010 10:21:31 -0700 (PDT) From: lilyevsky To: users@activemq.apache.org Subject: Re: Another case of javax.jms.JMSException: java.io.EOFException In-Reply-To: MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable X-Nabble-From: lilyevsky@mooncapital.com References: <29288496.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org No, but I do process them asynchronously. The actual consumer saves the message in the queue and ends the onMessage() call. Another thread picks it up from the queue and does the actual processing. Even if there was concurrent access, why should it be a problem? The messag= e on the receiving side is read-only anyway. Gary Tully wrote: >=20 > Is there any possible concurrent access to that message? >=20 > On 28 July 2010 17:34, lilyevsky 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 cas= e >> 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(). It is probably caused >> by >> the fact that in the message printout it says "properties =3D 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 o= n >> 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=3D0 on both sender and >> receiver, it does not help. >> >> What is the mystery? >> >> =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D >> >> [2010-07-28 11:34:08.516] ERROR =C2=A0Thread-7 >> com.moon.data.rtfeed.client.ClientSubscription =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0Problem >> reading message ActiveMQMapMessage {commandId =3D 1992420, responseRequi= red >> =3D >> true, messageId =3D >> ID:mcny9.mooncapital.corp-39424-1280328991613-2:0:2:1:1984887, >> originalDestination =3D null, originalTransactionId =3D null, producerId= =3D >> ID:mcny9.mooncapital.corp-39424-1280328991613-2:0:2:1, destination =3D >> topic://MKTDATA, transactionId =3D null, expiration =3D 0, timestamp =3D >> 1280331248515, arrival =3D 0, brokerInTime =3D 1280331248515, brokerOutT= ime =3D >> 1280331248515, correlationId =3D null, replyTo =3D null, persistent =3D = true, >> type >> =3D null, priority =3D 4, groupID =3D null, groupSequence =3D 0, targetC= onsumerId >> =3D >> null, compressed =3D false, userID =3D null, content =3D >> org.apache.activemq.util.ByteSequence@70e14f34, marshalledProperties =3D >> org.apache.activemq.util.ByteSequence@581718d1, dataStructure =3D null, >> redeliveryCounter =3D 0, size =3D 0, properties =3D null, readOnlyProper= ties =3D >> true, readOnlyBody =3D true, droppable =3D false} ActiveMQMapMessage{ >> theTable =3D >> {} } javax.jms.JMSException: java.io.EOFException >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.= java:62) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.command.ActiveMQMessage.propertyExists(ActiveMQMessa= ge.java:274) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> com.moon.data.rtfeed.client.ClientSubscription$DataTransformer.onMessage= (ClientSubscription.java:478) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> com.moon.data.rtfeed.jms.JmsReceiver$MessageDispatcher.run(JmsReceiver.j= ava:69) >> Caused by: java.io.EOFException: null >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at java.io.DataInputStream.readInt(DataInputS= tream.java:375) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(Marsha= llingSupport.java:83) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.util.MarshallingSupport.unmarshalPrimitiveMap(Marsha= llingSupport.java:73) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.command.Message.unmarsallProperties(Message.java:189= ) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.command.Message.getProperties(Message.java:162) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0at >> org.apache.activemq.command.ActiveMQMessage.propertyExists(ActiveMQMessa= ge.java:272) >> =C2=A0 =C2=A0 =C2=A0 =C2=A0... 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. >> >> >=20 >=20 >=20 > --=20 > http://blog.garytully.com >=20 > Open Source Integration > http://fusesource.com >=20 >=20 --=20 View this message in context: http://old.nabble.com/Another-case-of-javax.j= ms.JMSException%3A-java.io.EOFException-tp29288496p29288978.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.