You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Stephane GINER (JIRA)" <ji...@apache.org> on 2016/12/29 13:13:58 UTC
[jira] [Reopened] (AMQ-6551) DestinationDoesNotExistException on
valid temp queue
[ https://issues.apache.org/jira/browse/AMQ-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephane GINER reopened AMQ-6551:
---------------------------------
The problem is present when I use a virtual topic with 5 consumers
> DestinationDoesNotExistException on valid temp queue
> ----------------------------------------------------
>
> Key: AMQ-6551
> URL: https://issues.apache.org/jira/browse/AMQ-6551
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.7.0, 5.12.0, 5.14.3
> Environment: Windows 8.1
> Reporter: Stephane GINER
>
> On the client
> ----------------
> I have a producer who create a temporary destination to use in request/response call.
> I create a consumer on this temporary destination.
> This temporary destination is set in JMSReplyTo of the message and I send the message in a Topic.
> And I listen on temporary desination with the receive(timeout) method.
> On the server
> ------------------
> I get the message, extract the temporary destination from the JMSReplyTo field and I send back the message in this destination.
> Sometime I get this exception
> org.apache.activemq.DestinationDoesNotExistException: The destination temp-queue://ID:enovacom-sgine-63054-1482936486117-75:1:1 does not exist.
> at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:168)
> at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:348)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:172)
> at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:200)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:172)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:172)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:172)
> at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:177)
> at org.apache.activemq.broker.region.RegionBroker.addProducer(RegionBroker.java:398)
> at org.apache.activemq.broker.jmx.ManagedRegionBroker.addProducer(ManagedRegionBroker.java:267)
> at org.apache.activemq.broker.BrokerFilter.addProducer(BrokerFilter.java:107)
> at org.apache.activemq.advisory.AdvisoryBroker.addProducer(AdvisoryBroker.java:188)
> at org.apache.activemq.broker.CompositeDestinationBroker.addProducer(CompositeDestinationBroker.java:56)
> at org.apache.activemq.broker.BrokerFilter.addProducer(BrokerFilter.java:107)
> at org.apache.activemq.broker.BrokerFilter.addProducer(BrokerFilter.java:107)
> at org.apache.activemq.broker.MutableBrokerFilter.addProducer(MutableBrokerFilter.java:112)
> at org.apache.activemq.broker.TransportConnection.processAddProducer(TransportConnection.java:618)
> at org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java:108)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:338)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:300)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
> at java.lang.Thread.run(Thread.java:744)
> When the exception occurd on the server, sometime the message is delivered to the client thru the temporary queue, sometime not.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)