activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: activemq failed to delete temporary queue
Date Wed, 16 Oct 2013 16:33:25 GMT
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 <zenmatix@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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message