如何在 spring 集成中使用AMQ PooledConnectionFactory？-Java 学习之路

我正在使用与spring Integration 2.1.3和spring 3.0.5集成的activemq 3.7和activemq pool 3.7库 . 当我试图像这样定义connectionFactory时，我得到了下面的例外

<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory">
        <bean class="org.apache.activemq.pool.PooledConnectionFactory"
            destroy-method="stop">
            <property name="connectionFactory">
                <bean class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
                    <constructor-arg name="brokerURL" value="${jms.broker.url}" />
                </bean>
            </property>
        </bean>
    </property>
    <property name="sessionCacheSize" value="10" />
    <property name="cacheProducers" value="false" />
</bean>

这是一个例外：

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'connectionFactory' defined in class path resource 
[META-INF/integration-context.xml]: 
Cannot create inner bean 'org.apache.activemq.pool.PooledConnectionFactory#1445748' 
of type [org.apache.activemq.pool.PooledConnectionFactory] 
while setting bean property 'targetConnectionFactory'; nested exception is 
org.springframework.beans.factory.BeanCreationException: 
Error creating bean with name 'org.apache.activemq.pool.PooledConnectionFactory#1445748' 
defined in class path resource [META-INF/integration-context.xml]: 
Initialization of bean failed; 
nested exception is java.lang.reflect.MalformedParameterizedTypeException

如果我使用ActiveMQConnectionFactory而不是PooledConnectionFactory一切都很好，但我有性能我有性能问题 .

2 回答

0

第一：你能展示堆栈跟踪的其余部分以及你的“jms.broker.url”属性的值吗？

第二：如果用Spring的“缓存”CF包装，真的没有必要使用“混合”CF

回复于 2024-04-24T17:28:45+08:00
0
Spring使用无界通配符方法抛出异常：
```
public ObjectPoolFactory<?> getPoolFactory() {
    return null;
}
```
但是还没有找到解决方案 .
回复于 2024-04-24T17:28:45+08:00

如何在 spring 集成中使用AMQ PooledConnectionFactory？

2 回答

相关问题