Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 61343200BF8 for ; Thu, 29 Dec 2016 14:14:00 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 60320160B2D; Thu, 29 Dec 2016 13:14:00 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 8D8FB160B45 for ; Thu, 29 Dec 2016 14:13:59 +0100 (CET) Received: (qmail 16909 invoked by uid 500); 29 Dec 2016 13:13:58 -0000 Mailing-List: contact issues-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list issues@activemq.apache.org Received: (qmail 16884 invoked by uid 99); 29 Dec 2016 13:13:58 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 29 Dec 2016 13:13:58 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 6D1682C2A67 for ; Thu, 29 Dec 2016 13:13:58 +0000 (UTC) Date: Thu, 29 Dec 2016 13:13:58 +0000 (UTC) From: "Stephane GINER (JIRA)" To: issues@activemq.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (AMQ-6551) DestinationDoesNotExistException on valid temp queue MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 29 Dec 2016 13:14:00 -0000 [ https://issues.apache.org/jira/browse/AMQ-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane GINER updated AMQ-6551: -------------------------------- Attachment: (was: SyncAsyncProducer.java) > 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)