Hi Sylvain
In the stack trace I can ind following message
Could not refresh JMS Connection for destination 'octopus.recepisse.out'
- retrying in 5000 ms
You routes below don't use destination named 'octopus.recepisse.out'. Do
you have any other routes using this destination? Probably there is a
problem. The route below looks ok.
Regards
Krzysztof
On 18-Nov-2014 12:07, Sylvain Mougenot wrote:
> Using
> servicemix 5.3.0
> java : java-1.7.0-openjdk-1.7.0.71.x86_64/jre
> os : centos 6
>
> Migrating from servicemix 4.5.1.
> Activemq config is attached to this email.
>
> I've not changed many things from defaults :
> - deployed feature for hawtio, webconsole, activemq-web-console
> - changed logging properties
> - added my nexus url
> - deployed a few simple camel routes (copy from one queue to another)
>
> Trouble:
> Camel routes seems to have trouble to access activemq queues (I do not use
> topics).
> Maybe external connections might have the same trouble (but they manage to
> reconnect).
> It looks like activemq refuses clients to connect saying "already connected
> from" (but I'm not using durable subscription on a topic).
>
> Sample Log :
> 2014-11-18 11:09:52,696 | ERROR | s.recepisse.out] |
> faultJmsMessageListenerContainer | 110 -
> org.apache.servicemix.bundles.spring-jms - 3.2.9.RELEASE_1 | Could not
> refresh JMS Connection for destination 'octopus.recepisse.out' - retrying in
> 5000 ms. Cause: Broker: amq-broker - Client:
> ID:vSmxInt1-51774-1416304941057-2:6 already connected from vm://amq-broker#10
> 2014-11-18 11:09:52,695 | WARN | /amq-broker#11-1 | TransportConnection
> | 89 - org.apache.activemq.activemq-osgi - 5.10.0 | Failed to add
> Connection ID:vSmxInt1-51774-1416304941057-3:6
> javax.jms.InvalidClientIDException: Broker: amq-broker - Client:
> ID:vSmxInt1-51774-1416304941057-2:6 already connected from vm://amq-broker#10
> at
> org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:246)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:231)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:92)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:89)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:92)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:92)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:97)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:764)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:148)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:246)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)[89:org.apache.activemq.activemq-osgi:5.10.0]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_71]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_71]
> at java.lang.Thread.run(Thread.java:745)[:1.7.0_71]
>
> Sample route :
> Java code
> public void configure() throws Exception {
>
> from("jms:queue:v6.facturation.synchro.out").to("jms:queue:v6.messaging.facturation.in?disableReplyTo=true");
>
> from("jms:queue:v5.facturation.synchro.out").to("jms:queue:v6.messaging.facturation.in?disableReplyTo=true");
> }
> Camel-context
> <beans ...>
> <osgi:reference id="pooledConnectionFactory"
> interface="javax.jms.ConnectionFactory" />
>
> <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
> <property name="connectionFactory" ref="pooledConnectionFactory"/>
> </bean>
>
> <camelContext id="camelContext"
> xmlns="http://camel.apache.org/schema/spring"; >
> <package>fr.sogelink.esb.facturation.routes</package>
> </camelContext>
> </beans>
>
--
Krzysztof Sobkowiak
JEE & OSS Architect | Technical Architect @ Capgemini | Committer @ ASF
Capgemini <http://www.pl.capgemini.com/> | Software Solutions Center
<http://www.pl.capgemini-sdm.com/> | Wroclaw
e-mail: [email protected] <mailto:[email protected]> |
Twitter: @KSobkowiak
Calendar: http://goo.gl/yvsebC
