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