Hi Do you use embedded active or standalone ?
Regards JB Sent from my Samsung Galaxy smartphone. -------- Original message -------- From: Sylvain Mougenot <[email protected]> Date:18/11/2014 12:07 (GMT+01:00) To: [email protected] Cc: Subject: servicemix 5.3.0 trouble with jms connection to activemq : "already connected from" 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>
