2 Replies Latest reply on Oct 11, 2011 9:42 AM by lekkie_lomotayo

    Correlation ID mistaken mismatch problem in JMS?

    lekkie_lomotayo

      Hi all,

       

      I had this problem with a JMS request/reply. Even though the request correlation is same as the response correlation id, it still said it could match it.

       

      Here is the request log:

       

       

       

      18:58:10,677 | TemporaryQueueReplyManager       | 91 - org.apache.camel.camel-jms - 2.7.1.fuse-00-43 | Reply received for unknown correlationID -> ActiveMQTextMessage {commandId = 52, responseRequired = true, messageId = ID:TestESB-2538-1318010054316-18:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:TestESB-2538-1318010054316-18:1:1:1, destination = temp-queue://ID:TestESB-2538-1318010054316-76:1:1, transactionId = null, expiration = 0, timestamp = 1318010290677, arrival = 0, brokerInTime = 1318010290677, brokerOutTime = 1318010290677, correlationId = ID-TestESB-2542-1318010057455-22-4, replyTo = temp-queue://ID:TestESB-2538-1318010054316-76:1:1, persistent = true, type = null, priority = 9, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = org.apache.activemq.util.ByteSequence@13a9253, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {JMSXGroupFirstForConsumer=true, Date=[Fri, 07 Oct 2011 18:01:25 GMT], service=aero, CamelBeanMethodName=process, Connection=[close], CamelJmsDeliveryMode=2, Server=[Apache], RESPONSE_CODE=200}, readOnlyProperties = true, readOnlyBody = true, droppable = false, text =

      AKMSG - NO AIRLINE FOUND.

      }

      18:58:10,677 | DefaultMessageListenerContainer  | 92 - org.springframework.jms - 3.0.5.RELEASE | Execution of JMS message listener failed, and no ErrorHandler has been set.

      org.apache.camel.component.jms.reply.UnknownReplyMessageException: Reply received for unknown correlationID -> ActiveMQTextMessage {commandId = 52, responseRequired = true, messageId = ID:TestESB-2538-1318010054316-18:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:TestESB-2538-1318010054316-18:1:1:1, destination = temp-queue://ID:TestESB-2538-1318010054316-76:1:1, transactionId = null, expiration = 0, timestamp = 1318010290677, arrival = 0, brokerInTime = 1318010290677, brokerOutTime = 1318010290677, correlationId = ID-TestESB-2542-1318010057455-22-4, replyTo = temp-queue://ID:TestESB-2538-1318010054316-76:1:1, persistent = true, type = null, priority = 9, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = org.apache.activemq.util.ByteSequence@13a9253, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {JMSXGroupFirstForConsumer=true, Date=[Fri, 07 Oct 2011 18:01:25 GMT], CamelBeanMethodName=process, Connection=[close], CamelJmsDeliveryMode=2, Server=[Apache], RESPONSE_CODE=200}, readOnlyProperties = true, readOnlyBody = true, droppable = false, text =

      AKMSG - NO AIRLINE FOUND.


       

      Clearly, it says it doesnt know the correlation ID.