[jira] [Resolved] (CAMEL-18964) camel-activemq - JMS connection factory used if defined

["Claus Ibsen (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CAMEL-18964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Claus Ibsen resolved CAMEL-18964.
---------------------------------
    Resolution: Information Provided

> camel-activemq - JMS connection factory used if defined
> -------------------------------------------------------
>
>                 Key: CAMEL-18964
>                 URL: https://issues.apache.org/jira/browse/CAMEL-18964
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-activemq, camel-jms, camel-main
>    Affects Versions: 3.18.1, 3.20.1
>         Environment: camel-main, camel-activemq, camel-jms, jdk11, linux
>            Reporter: Christian Schubert-Huff
>            Priority: Minor
>
> We implemented an IBM-MQ to ActiveMQ bridge in camel-main, using camel-activemq and camel-jms for IBM-MQ, very similar to the documented [EIP|https://camel.apache.org/components/3.18.x/eips/messaging-bridge.html].
> This requires the definition of a custom connection factory, which is then set as connection factory of the JMS component:
> {noformat}
> camel.beans.mqConnectionFactory = #class:com.ibm.mq.jms.MQConnectionFactory
> camel.beans.mqConnectionFactory.HOSTNAME= mqhost
> camel.component.jms.connection-factory = #bean:mqConnectionFactory
> {noformat}
> Next, we configured the ActiveMQ component _without_ defining an explicit connection factory, like this:
> {noformat}
> camel.component.activemq.broker-url = activemqhost
> camel.component.activemq.username = jay
> camel.component.activemq.password = unit
> {noformat}
> We expected this to just work. Instead, the ActiveMQ component began using the mqConnectionFactory bean as its own connection factory, and the application started throwing errors.
> This occurs regardless of the value of {{camel.component.activemq.allow-auto-wired-connection-factory}} (which defaults to true).
> This can be reproduced with the following unit test (which uses ActiveMQConnectionFactory so it doesn't depend on proprietary JARs):
> {code:java}
> @Test
> public void testBindJmsConnectionFactory() {
>     Main main = new Main();
>     main.configure().addRoutesBuilder(new MyRouteBuilder());
>     // defining a connection factory for the JMS component
>     main.addProperty("camel.beans.jmscf", "#class:org.apache.activemq.ActiveMQConnectionFactory");
>     main.addProperty("camel.beans.jmscf.brokerURL", "jmshost");
>     main.addProperty("camel.component.jms.connection-factory", "#bean:jmscf");
>     main.addProperty("camel.component.activemq.broker-url", "activemqhost");
>     main.addProperty("camel.component.activemq.username", "jay");
>     main.addProperty("camel.component.activemq.password", "unit");
>     main.addProperty("camel.component.activemq.allow-auto-wired-connection-factory", "false");
>     main.start();
>     CamelContext camelContext = main.getCamelContext();
>     assertNotNull(camelContext);
>     ActiveMQConnectionFactory connectionFactory = camelContext.getRegistry().lookupByNameAndType("jmscf", ActiveMQConnectionFactory.class);
>     assertNotNull(connectionFactory);
>     
>     JmsComponent jmsComponent = camelContext.getComponent("jms", JmsComponent.class);
>     assertNotNull(jmsComponent);
>     assertSame(connectionFactory, jmsComponent.getConnectionFactory());
>     ActiveMQComponent activeMqComponent = camelContext.getComponent("activemq", ActiveMQComponent.class);
>     assertNotNull(activeMqComponent);
>     assertEquals("activemqhost", activeMqComponent.getBrokerURL());
>     assertEquals("jay", activeMqComponent.getUsername());
>     assertEquals("unit", activeMqComponent.getPassword());
>     assertNotSame(connectionFactory, activeMqComponent.getConnectionFactory());
>     main.stop();
> }
> {code}
> There is a workaround, which is to define an explicit connection factory on the ActiveMQ component:
> {noformat}
> camel.beans.amqcf = #class:org.apache.activemq.ActiveMQConnectionFactory
> camel.beans.amqcf.brokerURL = activemqhost
> camel.component.activemq.connection-factory = #bean:amqcf 
> {noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)