I'm using Camel 2.12.1 with SJMS on JBoss AS 7.2.0 with the ActiveMQ 5.7.0
resource adapter and an external broker.
My application has a route consuming request-reply messages from an
ActiveMQ queue via SJMS. The connection factory is obtained from JBoss via
@Resource injection.
When I stop my application, other producers may continue sending messages
to the queue.
When I restart my application, the producers and their associated temporary
reply queues may be gone.
Now the restarted application connects to the queue, processes a message
and fails sending a reply to stale temp queue, resulting in an exception
(see below) - as a result, the ActiveMQ connection is closed, and in the
debugger I can see that all ActiveMQ worker threads are terminated.
When producers send new messages (this time with active reply queues),
nothing happens. SJMS/ActiveMQ does not reconnect.
Everything works fine when replacing camel-sjms by camel-jms.
Is this a configuration issue, or a problem in SJMS? Any hints welcome...
Best regards,
Harald
----
11:48:45,506 WARN
[org.jboss.jca.core.connectionmanager.listener.TxConnectionListener]
(ActiveMQ Connection Executor: tcp://localhost/127.0.0.1:61616@49905)
IJ000305: Connection error occured:
org.jboss.jca.core.connectionmanager.listener.TxConnectionListener@2bc948fb[state=NORMAL
managed
connection=org.apache.activemq.ra.ActiveMQManagedConnection@29d997e5connection
handles=1 lastUse=1383907703668 trackByTx=false
pool=org.jboss.jca.core.connectionmanager.pool.strategy.OnePool@c8350dapool
internal
context=SemaphoreArrayListManagedConnectionPool@1311ea1[pool=ConnectionFactory]
xaResource=LocalXAResourceImpl@3fd1dca3[connectionListener=2bc948fb
connectionManager=6aec7210 warned=false currentXid=null
productName=ActiveMQ productVersion=5.7.0
jndiName=java:jboss/exported/jms/ConnectionFactory] txSync=null]:
javax.jms.JMSException: The destination
temp-queue://ID:tehh2d002-51935-1383907217133-1:2:2 does not exist.
at
org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:149)
at
org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:289)
at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
at
org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:175)
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.addProducer(RegionBroker.java:361)
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addProducer(ManagedRegionBroker.java:281)
at
org.apache.activemq.broker.BrokerFilter.addProducer(BrokerFilter.java:93)
at
org.apache.activemq.advisory.AdvisoryBroker.addProducer(AdvisoryBroker.java:163)
at
org.apache.activemq.broker.CompositeDestinationBroker.addProducer(CompositeDestinationBroker.java:56)
at
org.apache.activemq.broker.BrokerFilter.addProducer(BrokerFilter.java:93)
at
org.apache.activemq.broker.MutableBrokerFilter.addProducer(MutableBrokerFilter.java:99)
at
org.apache.activemq.broker.TransportConnection.processAddProducer(TransportConnection.java:511)
at org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java:105)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:152)
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:256)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
at java.lang.Thread.run(Thread.java:744) [rt.jar:1.7.0_45]
