You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by javaG <ze...@gmail.com> on 2013/10/04 05:17:30 UTC

activemq failed to delete temporary queue

In my client I use single temporary queue to get reply from consumers using
request reply pattern. I use the same temporary queue to get reply for
different kind of messages that are routed to other queues ( routing is done
with camel.xml under activemq) where consumers send the response back.  On
client my broker URL is:

private String brokerUrl =
"failover:(tcp://WPSR25S:61616)?timeout=9000&randomize=false&priorityBackup=true&jms.watchTopicAdvisories=false";

On producer broker URL is:

String brokerUrl =
"failover:(tcp://WPSR25S:61616)?timeout=9000&randomize=false&priorityBackup=true&jms.watchTopicAdvisories=false&jms.prefetchPolicy.queuePrefetch=1";


ActiveMQ throws these exceptions which causes activemq to mess up later
messaging:

Setup of JMS message listener invoker failed for destination 'temporary' -
trying to recover. Cause: The Consumer is closed
 INFO | failed to delete Temporary Queue
"temp-queue://ID:WPSR25S-61894-1380843220185-7:1:1" on closing pooled
connection: The connection i
s already closed
 INFO | Successfully refreshed JMS Connection
 WARN | Async error occurred:
org.apache.activemq.DestinationDoesNotExistException: The destination
temp-queue://ID:WPSR25S-61894-138084322
0185-7:1:1 does not exist.
org.apache.activemq.DestinationDoesNotExistException: The destination
temp-queue://ID:WPSR25S-61894-1380843220185-7:1:1 does not exist.
        at
org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:148)
        at
org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:277)
        at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
        at
org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:174)
        at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
        at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
        at
org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
        at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:387)
        at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:282)
        at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
        at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
        at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:317)
        at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
        at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:499)
        at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:749)
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:329)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
        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:288)
        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:662)



This has slowed me down and I am not able to figure it out yet. I tried to
tweak broker URLs but still got same issues.




--
View this message in context: http://activemq.2283324.n4.nabble.com/activemq-failed-to-delete-temporary-queue-tp4672253.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: activemq failed to delete temporary queue

Posted by Christian Posta <ch...@gmail.com>.
Looks like the connection that created the temporary destination closed,
and in doing so, removed any temp destinations it created (as designed).
And then your respondent tried to use the temp destination, but temp dests
cannot be added on the fly. Are you using connection pooling? What are your
pooling settings?


On Thu, Oct 3, 2013 at 8:17 PM, javaG <ze...@gmail.com> wrote:

> In my client I use single temporary queue to get reply from consumers using
> request reply pattern. I use the same temporary queue to get reply for
> different kind of messages that are routed to other queues ( routing is
> done
> with camel.xml under activemq) where consumers send the response back.  On
> client my broker URL is:
>
> private String brokerUrl =
>
> "failover:(tcp://WPSR25S:61616)?timeout=9000&randomize=false&priorityBackup=true&jms.watchTopicAdvisories=false";
>
> On producer broker URL is:
>
> String brokerUrl =
>
> "failover:(tcp://WPSR25S:61616)?timeout=9000&randomize=false&priorityBackup=true&jms.watchTopicAdvisories=false&jms.prefetchPolicy.queuePrefetch=1";
>
>
> ActiveMQ throws these exceptions which causes activemq to mess up later
> messaging:
>
> Setup of JMS message listener invoker failed for destination 'temporary' -
> trying to recover. Cause: The Consumer is closed
>  INFO | failed to delete Temporary Queue
> "temp-queue://ID:WPSR25S-61894-1380843220185-7:1:1" on closing pooled
> connection: The connection i
> s already closed
>  INFO | Successfully refreshed JMS Connection
>  WARN | Async error occurred:
> org.apache.activemq.DestinationDoesNotExistException: The destination
> temp-queue://ID:WPSR25S-61894-138084322
> 0185-7:1:1 does not exist.
> org.apache.activemq.DestinationDoesNotExistException: The destination
> temp-queue://ID:WPSR25S-61894-1380843220185-7:1:1 does not exist.
>         at
>
> org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:148)
>         at
>
> org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:277)
>         at
>
> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>         at
>
> org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:174)
>         at
>
> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>         at
>
> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>         at
>
> org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
>         at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:387)
>         at
>
> org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:282)
>         at
> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
>         at
>
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
>         at
>
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:317)
>         at
>
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
>         at
>
> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:499)
>         at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:749)
>         at
>
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:329)
>         at
>
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
>         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:288)
>         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:662)
>
>
>
> This has slowed me down and I am not able to figure it out yet. I tried to
> tweak broker URLs but still got same issues.
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/activemq-failed-to-delete-temporary-queue-tp4672253.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta