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:23:58 UTC
[jira] [Issue Comment Deleted] (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 updated AMQ-6551:
--------------------------------
Comment: was deleted
(was:
The exception occurred because 2 listener started on the subject, but listener 2 uses the same temporary queue to send the reply, but when the message returns as the producer deletes the queue temporary.
Sorry for the disturbance:))
> 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
> Attachments: Main.java, MultiThreadSyncAsyncListener.java, MultiThreadSyncAsyncProducer2.java
>
>
> 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)