Are there any example demonstrate using camel route to Dual SSL connect to AMQ7?

Solution Verified - Updated -

Issue

We are trying to connect to AMQ7 using dual authentication based on Cert with the following Camel configuration, however, we are getting the error below:

<bean id="jmsActivemqSslConnectionFactory" class="org.apache.activemq.ActiveMQSslConnectionFactory">         
<property name="brokerURL" value="${activemq.broker.url}" ></property>
<!-- <property name="userName" value="${activemq.broker.username:#null}" ></property>
<property name="password" value="${activemq.broker.password:#null}" ></property> -->
<property name="trustStore" value="${activemq.ssl.truststore}" ></property>
<property name="trustStorePassword" value="${activemq.ssl.truststore.password}" ></property>
<property name="keyStore" value="${activemq.ssl.keystore}" ></property>
<property name="keyStorePassword" value="${activemq.ssl.keystore.password}" ></property>
<!-- <property name="clientFailureCheckPeriod" value="30000" ></property> -->
<!-- <property name="connectionTTL" value="30000" ></property> -->
</bean>
    <bean id="activemqCacheConnectionFactory"
        class="org.springframework.jms.connection.CachingConnectionFactory" primary="true">
        <property name="targetConnectionFactory" ref="jmsActivemqSslConnectionFactory" ></property>
        <property name="reconnectOnException" value="true" ></property>
        <property name="sessionCacheSize" value="50" ></property>
    </bean>

<bean id="activemq" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="activemqCacheConnectionFactory" ></property>
    </bean>

stacktrace:

Caused by: org.apache.activemq.transport.InactivityIOException: Cannot send, channel has already failed: tcp://127.0.0.1:5672
Caused by: javax.jms.JMSException: Cannot send, channel has already failed: tcp://127.0.0.1:5672 at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:72) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1410) at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1473) at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:325) at org.springframework.jms.connection.SingleConnectionFactory.createSession(SingleConnectionFactory.java:437) at org.springframework.jms.connection.CachingConnectionFactory.getSession(CachingConnectionFactory.java:236) at org.springframework.jms.connection.SingleConnectionFactory$SharedConnectionInvocationHandler.invoke(SingleConnectionFactory.java:604) at com.sun.proxy.$Proxy134.createSession(Unknown Source) at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:192) at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:475) ... 31 common frames omitted Caused by: org.apache.activemq.transport.InactivityIOException: Cannot send, channel has already failed: tcp://127.0.0.1:5672 at org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:328) at org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:317) at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85) at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:116) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81) at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1383) ... 39 common frames omitted

Environment

  • Red Hat JBoss Fuse 6.3.0
  • Red Hat JBoss Fuse 7.X
  • Red Hat JBoss AMQ 7.X

Subscriber exclusive content

A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.

Current Customers and Partners

Log in for full access

Log In