You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by rmueller <ra...@inventage.com> on 2014/02/06 08:10:09 UTC
Errors because ActiveMQ is shutting down before CamelContext
We use ActiveMQ in standalone mode with integrated Camel.
As ActiveMQ is shutting down before CamelContext we get the following WARN /
ERROR messages in the logfile.
WARN | Setup of JMS message listener invoker failed for destination
'que.contactCustomer.in' - trying to recover. Cause: peer (vm://myBroker#1)
stopped. | org.apache.camel.component.jms.DefaultJmsMessageListenerContainer
| Camel (camel) thread #0 - JmsConsumer[que.contactCustomer.in]
ERROR | Could not refresh JMS Connection for destination
'que.contactCustomer.in' - retrying in 5000 ms. Cause: Error while
attempting to retrieve a connection from the pool; nested exception is
javax.jms.JMSException: Could not create Transport. Reason:
java.io.IOException: Broker named 'myBroker' does not exist. |
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer | Camel
(camel) thread #0 - JmsConsumer[que.contactCustomer.in]
Compare to the startup duration (2 sec), the shutdown takes forever (11
sec).
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:${activemq.conf}/credentials.properties</value>
</property>
</bean>
<bean id="logQuery"
class="org.fusesource.insight.log.log4j.Log4jLogQuery"
lazy-init="false" scope="singleton"
init-method="start" destroy-method="stop">
</bean>
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring"
depends-on="broker">
<route id="contactCustomer">
<from uri="activemq:que.contactCustomer.in"/>
<to uri="activemq:que.contactCustomer.out"/>
</route>
</camelContext>
<bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent"
depends-on="broker">
<property name="brokerURL"
value="vm://myBroker?create=false&waitForStart=5000"/>
</bean>
<broker id="broker" useJmx="true"
xmlns="http://activemq.apache.org/schema/core" brokerName="myBroker"
dataDirectory="${activemq.data}">
<destinations>
<queue physicalName="que.contactCustomer.in"/>
<queue physicalName="que.contactCustomer.out"/>
<queue physicalName="que.contactCustomer.dlq"/>
</destinations>
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" >
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="1000"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<persistenceAdapter>
<kahaDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage percentOfJvmHeap="70" />
</memoryUsage>
<storeUsage>
<storeUsage limit="100 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="50 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp"
uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp"
uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt"
uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws"
uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
<shutdownHooks>
<bean xmlns="http://www.springframework.org/schema/beans"
class="org.apache.activemq.hooks.SpringContextHook" />
</shutdownHooks>
</broker>
<import resource="jetty.xml"/>
</beans>
--
View this message in context: http://activemq.2283324.n4.nabble.com/Errors-because-ActiveMQ-is-shutting-down-before-CamelContext-tp4677524.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Errors because ActiveMQ is shutting down before CamelContext
Posted by rmueller <ra...@inventage.com>.
I forgot to mention that we are using ActiveMQ 5.9 version.
--
View this message in context: http://activemq.2283324.n4.nabble.com/Errors-because-ActiveMQ-is-shutting-down-before-CamelContext-tp4677524p4677530.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Errors because ActiveMQ is shutting down before CamelContext
Posted by rmueller <ra...@inventage.com>.
Thanks for your reply. My config is already using the depends-on and the
<camelContext> is defined before the <broker> element.
The only difference I see is the missing <shutdownHooks> within the <broker>
element. But without that entry the CamelContext would not shutdown at all.
As we are using a standalone ActiveMQ the useShutdownHook="false" attribute
for <broker> element does not make sense.
What else could be the problem?
--
View this message in context: http://activemq.2283324.n4.nabble.com/Errors-because-ActiveMQ-is-shutting-down-before-CamelContext-tp4677524p4677617.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Errors because ActiveMQ is shutting down before CamelContext
Posted by Claus Ibsen <cl...@gmail.com>.
Hi
See this example which has embedded broker and camel, and how using
depends-on helps the ordering.
https://github.com/apache/camel/blob/master/examples/camel-example-management/src/main/resources/META-INF/spring/camel-context.xml
On Thu, Feb 6, 2014 at 8:10 AM, rmueller <ra...@inventage.com> wrote:
> We use ActiveMQ in standalone mode with integrated Camel.
>
> As ActiveMQ is shutting down before CamelContext we get the following WARN /
> ERROR messages in the logfile.
>
> WARN | Setup of JMS message listener invoker failed for destination
> 'que.contactCustomer.in' - trying to recover. Cause: peer (vm://myBroker#1)
> stopped. | org.apache.camel.component.jms.DefaultJmsMessageListenerContainer
> | Camel (camel) thread #0 - JmsConsumer[que.contactCustomer.in]
>
> ERROR | Could not refresh JMS Connection for destination
> 'que.contactCustomer.in' - retrying in 5000 ms. Cause: Error while
> attempting to retrieve a connection from the pool; nested exception is
> javax.jms.JMSException: Could not create Transport. Reason:
> java.io.IOException: Broker named 'myBroker' does not exist. |
> org.apache.camel.component.jms.DefaultJmsMessageListenerContainer | Camel
> (camel) thread #0 - JmsConsumer[que.contactCustomer.in]
>
> Compare to the startup duration (2 sec), the shutdown takes forever (11
> sec).
>
>
>
> <beans
> xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd
> http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd">
>
>
> <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
> <property name="locations">
> <value>file:${activemq.conf}/credentials.properties</value>
> </property>
> </bean>
>
>
> <bean id="logQuery"
> class="org.fusesource.insight.log.log4j.Log4jLogQuery"
> lazy-init="false" scope="singleton"
> init-method="start" destroy-method="stop">
> </bean>
>
> <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring"
> depends-on="broker">
>
>
> <route id="contactCustomer">
> <from uri="activemq:que.contactCustomer.in"/>
> <to uri="activemq:que.contactCustomer.out"/>
> </route>
> </camelContext>
>
> <bean id="activemq"
> class="org.apache.activemq.camel.component.ActiveMQComponent"
> depends-on="broker">
> <property name="brokerURL"
> value="vm://myBroker?create=false&waitForStart=5000"/>
> </bean>
>
>
> <broker id="broker" useJmx="true"
> xmlns="http://activemq.apache.org/schema/core" brokerName="myBroker"
> dataDirectory="${activemq.data}">
>
> <destinations>
> <queue physicalName="que.contactCustomer.in"/>
> <queue physicalName="que.contactCustomer.out"/>
> <queue physicalName="que.contactCustomer.dlq"/>
> </destinations>
>
> <destinationPolicy>
> <policyMap>
> <policyEntries>
> <policyEntry topic=">" >
>
> <pendingMessageLimitStrategy>
> <constantPendingMessageLimitStrategy limit="1000"/>
> </pendingMessageLimitStrategy>
> </policyEntry>
> </policyEntries>
> </policyMap>
> </destinationPolicy>
>
>
>
> <managementContext>
> <managementContext createConnector="false"/>
> </managementContext>
>
>
> <persistenceAdapter>
> <kahaDB directory="${activemq.data}/kahadb"/>
> </persistenceAdapter>
>
>
>
> <systemUsage>
> <systemUsage>
> <memoryUsage>
> <memoryUsage percentOfJvmHeap="70" />
> </memoryUsage>
> <storeUsage>
> <storeUsage limit="100 gb"/>
> </storeUsage>
> <tempUsage>
> <tempUsage limit="50 gb"/>
> </tempUsage>
> </systemUsage>
> </systemUsage>
>
>
> <transportConnectors>
>
> <transportConnector name="openwire"
> uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
> <transportConnector name="amqp"
> uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
> <transportConnector name="stomp"
> uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
> <transportConnector name="mqtt"
> uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
> <transportConnector name="ws"
> uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
> </transportConnectors>
>
>
> <shutdownHooks>
> <bean xmlns="http://www.springframework.org/schema/beans"
> class="org.apache.activemq.hooks.SpringContextHook" />
> </shutdownHooks>
>
> </broker>
>
>
> <import resource="jetty.xml"/>
>
> </beans>
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Errors-because-ActiveMQ-is-shutting-down-before-CamelContext-tp4677524.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
--
Claus Ibsen
-----------------
Red Hat, Inc.
Email: cibsen@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Make your Camel applications look hawt, try: http://hawt.io