activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephane GINER (JIRA)" <j...@apache.org>
Subject [jira] [Issue Comment Deleted] (AMQ-6551) DestinationDoesNotExistException on valid temp queue
Date Thu, 29 Dec 2016 13:23:58 GMT

     [ 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)

Mime
View raw message