4

我有一个使用 JNDI 和 Spring 的 Camel Context 的良好工作 XML 配置

后来 Solace.JndiObjectFactoryBean 被用作 connectionFactory

<bean id="Solace.JmsComponent" class="  on">
    <property name="connectionFactory" ref="Solace.JndiObjectFactoryBean" />
    <property name="destinationResolver" ref="Solace.JndiDestinationResolver" />
</bean>

我正在尝试将其转换为从org.apache.camel.spring.javaconfig.CamelConfiguration. 但是有一个问题。当我尝试在 JMS 组件上设置连接工厂时 component.setConnectionFactory(getJndiObjectFactoryBean()); getJndiObjectFactoryBean()，我得到一个编译时异常：

The method setConnectionFactory(ConnectionFactory) in the type JmsComponent 
is not applicable for the arguments (JndiObjectFactoryBean)

但是，当我尝试将从 getJndiObjectFactoryBean 返回的 JndiObjectFactoryBean 显式转换为 SolConnectionFactory 时，出现运行时错误

016-02-05 17:39:09,234|[localhost-startStop-1]|[]|[]|[ERROR] web.context.ContextLoader [line:307] Context initialization failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getJMSConfiguration' defined in class path resource [com//camel
/CamelRoutesConfig.class]: Instantiation of bean failed; nested exception is org
.springframework.beans.factory.BeanDefinitionStoreException: Factory method [public org.apache.camel.component.jms.JmsConfiguration com.camel.CamelRoutesConfig.getJMSConfiguration()] threw exception; nested exception is java.lang.ClassCastException: org.springframework.jndi.JndiObjectFactoryBean$$EnhancerByCG
LIB$$18b94f95 cannot be cast to com.solacesystems.jms.SolConnectionFactory
    at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsi
ngFactoryMethod(ConstructorResolver.java:581)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory
.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1029)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory
.createBeanInstance(AbstractAutowireCapableBeanFactory.java:925)

我相信在类路径中确实有必要的罐子。sol-common-xyzjar、sol-jcsmp-xyzjar、sol-jms-xyzjar

4

3 回答 3

5

AJndiObjectFactoryBean不能转换为 a ConnectionFactory。

有两种选择：

  1. JndiObjectFactoryBean.getObject()在您的方法JndiObjectFactoryBean返回的那个中使用。getJndiObjectFactoryBean()

  2. 让 Spring 提供ConnectionFactory.

    ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("config.xml"); ConnectionFactory connectionFactory = (ConnectionFactory) context.getBean("Solace.JndiObjectFactoryBean");

于 2016-02-10T05:14:54.460 回答
1

在将工作的 Spring XML 配置（被 Apache Camel 用于从 Weblogic JMS 服务器队列中读取）移植到 Spring-Boot 支持的 Java 配置时，我们遇到了类似的情况。

jmsConfiguration.setConnectionFactory( (javax.jms.ConnectionFactory)getJndiFactoryBean().getObject());

上面的代码做了模拟

<bean id="jmsConfiguration" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="jndiFactoryBean"/>
    <property name="destinationResolver" ref="jndiDestinationResolver"/>
</bean>

（虽然不清楚 Spring XML 在幕后做了什么额外的事情，因为它不像设置jndiFactoryBeanon那样简单jmsConfiguration）

于 2016-09-14T02:33:39.197 回答
1

如果您使用 getObject() 方法，请确保在使用 getObject() 之前调用 afterPropertiesSet()

org.springframework.jndi.JndiObjectFactoryBean cf = new org.springframework.jndi.JndiObjectFactoryBean();
JndiTemplate jndiTemplate = new org.springframework.jndi.JndiTemplate();
Properties environment = new Properties();
environment.setProperty("java.naming.factory.initial", "com.xxx"); //initial context
environment.setProperty("java.naming.provider.url", "xxx://xxx"); //url
jndiTemplate.setEnvironment(environment);
cf.setJndiTemplate(jndiTemplate);
cf.setJndiName("XXX");
//System.out.println(cf.getObject()); //null
cf.afterPropertiesSet();
//System.out.println(cf.getObject()); //now has the value

org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter adapter = new org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter();
adapter.setTargetConnectionFactory((ConnectionFactory) cf.getObject());
于 2016-10-27T22:55:08.883 回答