5 Replies Latest reply on Oct 4, 2011 9:02 AM by isendel

    The destination temp-queue://*** does not exist JMSException

    isendel

      ESB project in Fuse JIRA is not presented in list for public issues creation, so I'll describe

      my problem here.

      After moving from Fuse ESB with version 4.4.0-fuse-00-27 to 4.4.0-fuse-00-43 or even latest available for now 4.4.1-fuse-00-08 I've faced a problem with InOut JMS queue.

      A have a route that publish a message from webservice to InOut queue and await for response to created temporary queue. In old version that works fine, but newer ones causes an exception occurs immediately after request message publication:

       

      10:15:22,006 | DEBUG | Task-2574 | Queue                            | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | stateQueue toPageIn: 1, Inflight: 0, pagedInMessages.size 0, enqueu

      eCount: 6, dequeueCount: 5

      10:15:22,059 | DEBUG | /127.0.0.1:42625 | AbstractRegion                   | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | Removing destination: temp-queue://ID:siu-esb.std.gostr.ru-45213-13

      17670825670-8:12:1

      10:15:22,060 | DEBUG | /127.0.0.1:42625 | Queue                            | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | temp-queue://ID:siu-esb.std.gostr.ru-45213-1317670825670-8:12:1 rem

      ove sub: QueueSubscription: consumer=ID:siu-esb.std.gostr.ru-45213-1317670825670-8:12:1:1, destinations=1, dispatched=0, delivered=0, pending=0, lastDeliveredSeqId: 0, dequeues: 0, dispatched: 0, inflight: 0

      10:15:22,060 | DEBUG | /127.0.0.1:42625 | Queue                            | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | ID:siu-esb.std.gostr.ru-45213-1317670825670-8:12:1 toPageIn: 0, Inf

      light: 0, pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0

      10:15:22,061 | DEBUG | 16.130.146:39092 | AbstractRegion                   | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | siu1 adding destination: temp-queue://ID:siu-esb.std.gostr.ru-45213

      -1317670825670-8:12:1

      10:15:22,062 | DEBUG | /127.0.0.1:42625 | AbstractRegion                   | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | Removing destination: topic://ActiveMQ.Advisory.Producer.Queue.ID:S

      iu-esb.std.gostr.ru-45213-1317670825670-8:12:1

      10:15:22,064 | DEBUG | 16.130.146:39092 | Service                          | 252 - org.apache.activemq.activemq-core - 5.6.0.fuse-SNAPSHOT | Error occured while processing sync command: ActiveMQTextMessage {c

      ommandId = 29, responseRequired = true, messageId = ID:siu-engine.std.gostr.ru-42213-1317633165786-0:1765:1:8:1, originalDestination = null, originalTransactionId = null, producerId = ID:siu-engine.std.gostr.

      ru-42213-1317633165786-0:1765:1:8, destination = temp-queue://ID:siu-esb.std.gostr.ru-45213-1317670825670-8:12:1, transactionId = null, expiration = 0, timestamp = 1317708922049, arrival = 0, brokerInTime = 1

      317708922060, brokerOutTime = 0, correlationId = ID-siu-esb-std-gostr-ru-35370-1317670835926-0-31, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsum

      erId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, text = {"Message":{"RequestIdRef":{"$":"?"},"Sender"...a4d82ce2"}}}}, exception: javax.jms.JMSException: The destination temp-queue://ID:siu-esb.std.gostr.ru-45213-1317670825670-8:12:1 does not exist.

      javax.jms.JMSException: The destination temp-queue://ID:siu-esb.std.gostr.ru-45213-1317670825670-8:12:1 does not exist.

              at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:159)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:308)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:155)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:521)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:301)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:306)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:470)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:318)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:181)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

              at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)[252:org.apache.activemq.activemq-core:5.6.0.fuse-SNAPSHOT]

       

      Seems that bug was fixed in latest Message Broker versions (MB-934). I've tried to use a 5.6-SNAPSHOT version of ActiveMQ, which has this bug resolved, but that gave no results (perhaps my approach here was mistaken).