From dev-return-21726-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org Thu Aug 19 15:50:28 2010 Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 38885 invoked from network); 19 Aug 2010 15:50:28 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 19 Aug 2010 15:50:28 -0000 Received: (qmail 24943 invoked by uid 500); 19 Aug 2010 15:50:28 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 24873 invoked by uid 500); 19 Aug 2010 15:50:27 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 24865 invoked by uid 99); 19 Aug 2010 15:50:27 -0000 Received: from Unknown (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 19 Aug 2010 15:50:27 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.22] (HELO thor.apache.org) (140.211.11.22) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 19 Aug 2010 15:50:09 +0000 Received: from thor (localhost [127.0.0.1]) by thor.apache.org (8.13.8+Sun/8.13.8) with ESMTP id o7JFnljj004203 for ; Thu, 19 Aug 2010 15:49:48 GMT Message-ID: <19250293.10791282232987608.JavaMail.jira@thor> Date: Thu, 19 Aug 2010 11:49:47 -0400 (EDT) From: "Leonid Ilyevsky (JIRA)" To: dev@activemq.apache.org Subject: [jira] Commented: (AMQ-2860) EOFException and ActiveMQMapMessage with null properties In-Reply-To: <11318447.58271281058634436.JavaMail.jira@thor> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/AMQ-2860?page=3Dcom.atlassi= an.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D61= 294#action_61294 ]=20 Leonid Ilyevsky commented on AMQ-2860: -------------------------------------- It is still happening in my environment. I did some browsing of ActiveMQ source code to understand where it may come= from.=20 In my code exception happens right in the beginning of the onMessage() call= back, where I am trying to call propertyExists() method on the message. I see that since this is the first call that requires properties informatio= n, the code in the Message class tries to create properties map from the ma= rshalledProperties, which is a ByteSequence. It fails right at the start, in readInt() call, which means that the sequen= ce does not even have the 4 bytes (I suspect it may be empty). So, the only explanation for this problem is that the byte sequence represe= nting the message came from the socket truncated. > EOFException and ActiveMQMapMessage with null properties > -------------------------------------------------------- > > Key: AMQ-2860 > URL: https://issues.apache.org/activemq/browse/AMQ-2860 > Project: ActiveMQ > Issue Type: Bug > Affects Versions: 5.3.2 > 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 =3D null". This looks like corrupt message. My sen= der sends messages of the ActiveMQMapMessage type and they all have some pr= operties. > 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.da= ta.rtfeed.client.ClientSubscription Problem reading mess= age ActiveMQMapMessage {commandId =3D 2797499, responseRequired =3D true, m= essageId =3D ID:mcny9.mooncapital.corp-55291-1280869129156-2:1:1:1:2797495,= originalDestination =3D null, originalTransactionId =3D null, producerId = =3D ID:mcny9.mooncapital.corp-55291-1280869129156-2:1:1:1, destination =3D = topic://MKTDATA, transactionId =3D null, expiration =3D 0, timestamp =3D 12= 80894513809, arrival =3D 0, brokerInTime =3D 1280894513809, brokerOutTime = =3D 1280894513809, correlationId =3D null, replyTo =3D null, persistent =3D= true, type =3D null, priority =3D 4, groupID =3D null, groupSequence =3D 0= , targetConsumerId =3D null, compressed =3D false, userID =3D null, content= =3D org.apache.activemq.util.ByteSequence@6f539d49, marshalledProperties = =3D org.apache.activemq.util.ByteSequence@5a7b5cb8, dataStructure =3D null,= redeliveryCounter =3D 0, size =3D 0, properties =3D null, readOnlyProperti= es =3D true, readOnlyBody =3D true, droppable =3D false} ActiveMQMapMessage= { theTable =3D {} } javax.jms.JMSException: java.io.EOFException > at org.apache.activemq.util.JMSExceptionSupport.create(JMSExcepti= onSupport.java:62) > at org.apache.activemq.command.ActiveMQMessage.propertyExists(Act= iveMQMessage.java:274) > at com.moon.data.rtfeed.client.ClientSubscription$DataTransformer= .onMessage(ClientSubscription.java:463) > at com.moon.data.rtfeed.jms.JmsReceiver$MessageDispatcher.run(Jms= Receiver.java:71) > Caused by: java.io.EOFException: null > at java.io.DataInputStream.readInt(DataInputStream.java:375) > at org.apache.activemq.util.MarshallingSupport.unmarshalPrimitive= Map(MarshallingSupport.java:83) > at org.apache.activemq.util.MarshallingSupport.unmarshalPrimitive= Map(MarshallingSupport.java:73) > at org.apache.activemq.command.Message.unmarsallProperties(Messag= e.java:189) > at org.apache.activemq.command.Message.getProperties(Message.java= :162) > at org.apache.activemq.command.ActiveMQMessage.propertyExists(Act= iveMQMessage.java:272) > ... 2 common frames omitted --=20 This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.