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.
