[AMQ-325] "Could not find parts for fragemented message" error stop network connector

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.0
• Fix Version/s: 3.2
• Component/s: Connector
• Assignee: Unassigned
• Reporter: Hiram R. Chirino
• Created: 17/Aug/05 12:32
• Updated: 18/Oct/05 00:37
• Resolved: 18/Oct/05 00:37

Description

Mark Lewis <mark.lewis at mir3.com> reported:

After running more or less without any problems for a couple of days, I
suddenly got this message on one of the brokers in my network as it
processed a moderately large (1-2MB) message. After receiving this
message it appears to have broken the network connection without trying
to restart, even though I specified reliable: protocol for the network
channel.

09:10:51 WARN Async exception with no exception listener:
javax.jms.JMSException: Could not find parts for fragemented message:
ACTIVEMQ_TEXT_MESSAGE: id = 0 ActiveMQMessage

{ , jmsMessageID = ID:r2- d2-40063-1124130867102-118:0, bodyAsBytes = org.activemq.io.util.ByteArray@aa098a, readOnlyMessage = true, jmsClientID = 'qa_tahoe' , jmsCorrelationID = 'null' , jmsDestination = qa_tahoe_data, jmsReplyTo = null, jmsDeliveryMode = 2, jmsRedelivered = false, jmsType = 'null' , jmsExpiration = 0, jmsPriority = 4, jmsTimestamp = 1124205464502, properties = null, readOnlyProperties = true, entryBrokerName = 'ID:yoda-34917-1123719371107-0:0' , entryClusterName = 'default' , consumerNos = [0], transactionId = 'null' , xaTransacted = false, consumerIdentifer = 'ID:yoda-34923-1123719372923-0:0_NetworkChannel.14.14' , messageConsumed = true, transientConsumed = false, sequenceNumber = 0, deliveryCount = 1, dispatchedFromDLQ = false, messageAcknowledge = org.activemq.ActiveMQSession@1584a8b, jmsMessageIdentity = null, producerKey = ID:r2-d2-40063-1124130867102-118: }

, text = fragmented
message
javax.jms.JMSException: Could not find parts for fragemented message:
ACTIVEMQ_TEXT_MESSAGE: id = 0 ActiveMQMessage

{ , jmsMessageID = ID:r2- d2-40063-1124130867102-118:0, bodyAsBytes = org.activemq.io.util.ByteArray@aa098a, readOnlyMessage = true, jmsClientID = 'qa_tahoe' , jmsCorrelationID = 'null' , jmsDestination = qa_tahoe_data, jmsReplyTo = null, jmsDeliveryMode = 2, jmsRedelivered = false, jmsType = 'null' , jmsExpiration = 0, jmsPriority = 4, jmsTimestamp = 1124205464502, properties = null, readOnlyProperties = true, entryBrokerName = 'ID:yoda-34917-1123719371107-0:0' , entryClusterName = 'default' , consumerNos = [0], transactionId = 'null' , xaTransacted = false, consumerIdentifer = 'ID:yoda-34923-1123719372923-0:0_NetworkChannel.14.14' , messageConsumed = true, transientConsumed = false, sequenceNumber = 0, deliveryCount = 1, dispatchedFromDLQ = false, messageAcknowledge = org.activemq.ActiveMQSession@1584a8b, jmsMessageIdentity = null, producerKey = ID:r2-d2-40063-1124130867102-118: }

, text = fragmented
message
at org.activemq.ActiveMQSession.sendMessageAck
(ActiveMQSession.java:1159)
at org.activemq.ActiveMQSession.doAcknowledge
(ActiveMQSession.java:1092) at
org.activemq.ActiveMQSession.acknowledge(ActiveMQSession.java:1082)
at org.activemq.message.ActiveMQMessage.acknowledge
(ActiveMQMessage.java:1956)
at org.activemq.transport.NetworkMessageBridge.onMessage
(NetworkMessageBridge.java:217)
at org.activemq.ActiveMQMessageConsumer.processMessage
(ActiveMQMessageConsumer.java:447)
at org.activemq.ActiveMQSessionExecutor.dispatch
(ActiveMQSessionExecutor.java:110)
at org.activemq.ActiveMQSessionExecutor.run
(ActiveMQSessionExecutor.java:95)
at java.lang.Thread.run(Thread.java:534)
09:10:51 INFO channel status changed: Channel: tcp://localhost:61617
has stopped