Malformed message ?

[jayh <lo...@hotmail.com>]

I've been chasing a problem for a while in AMQ where at apparently random
intervals I get JMS disconnect events logged and an apparently corrupt
message in the persistence store leading to an eventual OOM. After a lot of
digging and full TRACE lavel logging the the only think I've been able to
find is this.

In the JMS header a good message has;
properties = {transformation=jms-xml}
But in a 'bad' message it only has properties = null

Could someone help me understand what may be going on here. This is a
message received from a upstream 3rd party supplier who apparently sees no
issues there end. When I get one of these messages I get an EOF error and
AMQ chokes as in the JIRA. If I connect via camel the same message still
comes in and throws an EOF error but Camel never passes it to the AMQ
persistence store so it doesn't lead to an OOM condition.

I've opened a  JIRA
<https://issues.apache.org/jira/projects/AMQ/issues/AMQ-7229>   as well but
not sure what info I might need to provide for this to be looked into.

Bad message full header:

2019-06-26 18:50:43,202 | DEBUG |
nrod://topic:TD_ALL_SIG_AREA?clientId=test.broker1%40test&durableSubscriptionName=td-test-test
consumer received JMS message: ActiveMQTextMessage {commandId = 2113027,
responseRequired = false, messageId =
ID:opendata-backend.rockshore.net-45497-1560093463062-11:26340:4:7:90688,
originalDestination = null, originalTransactionId = null, producerId =
ID:opendata-backend.rockshore.net-45497-1560093463062-11:26340:4:7,
destination = topic://TD_ALL_SIG_AREA, transactionId = null, expiration =
1561571743189, timestamp = 1561571443189, arrival = 0, brokerInTime =
1561571443190, brokerOutTime = 1561571443194, correlationId = null, replyTo
= null, persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = true, userID =
null, content = org.apache.activemq.util.ByteSequence@7eea0857,
marshalledProperties = org.apache.activemq.util.ByteSequence@dc68e3d,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = true, readOnlyBody = true, droppable = false,
jmsXGroupFirstForConsumer = false, text =
[{"SF_MSG":{"time":"1561571442000","area_id":...ata":"40"}}]} |
org.apache.camel.component.jms.EndpointMessageListener | Camel (Piper_Alpha)
thread #1 - JmsConsumer[TD_ALL_SIG_AREA]


Good message header:

2019-06-26 18:50:43,461 | DEBUG |
nrod://topic:TD_ALL_SIG_AREA?clientId=test.broker1%40test&durableSubscriptionName=td-test-test
consumer received JMS message: ActiveMQTextMessage {commandId = 2113029,
responseRequired = false, messageId =
ID:opendata-backend.rockshore.net-45497-1560093463062-11:26340:1:1:90442,
originalDestination = null, originalTransactionId = null, producerId =
ID:opendata-backend.rockshore.net-45497-1560093463062-11:26340:1:1,
destination = topic://TD_ALL_SIG_AREA, transactionId = null, expiration =
1561571743449, timestamp = 1561571443449, arrival = 0, brokerInTime =
1561571443450, brokerOutTime = 1561571443453, correlationId = null, replyTo
= null, persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = true, userID =
null, content = org.apache.activemq.util.ByteSequence@5b0352b8,
marshalledProperties = org.apache.activemq.util.ByteSequence@68ec1f70,
dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{transformation=jms-xml}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, jmsXGroupFirstForConsumer = false, text =
[{"CA_MSG":{"to":"0335","time":"1561571443000...ata":"CA"}}]} |
org.apache.camel.component.jms.EndpointMessageListener | Camel (Piper_Alpha)
thread #1 - JmsConsumer[TD_ALL_SIG_AREA]

Any help warmly received.




--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html