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 Main.java file start the broker.

SyncAsyncListener start the listener on the topic and send back the event on the temporary
queue when they get message.

SyncAsyncProducer send messages end listen on temporary queue.)

> 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