activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From javaG <zenma...@gmail.com>
Subject activemq failed to delete temporary queue
Date Fri, 04 Oct 2013 03:17:30 GMT
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.

Mime
View raw message