用于连接到 IBM MQ 的 Spring Boot CachingConnection 工厂

Question

我正在使用带有camel的spring boot最新版本3.0.1，并且需要进行IBM MQ连接来读取消息。 STS 显示以下错误。

错误 SingleConnectionFactory 类型中的 setTargetConnectionFactory(ConnectionFactory) 方法引用了缺少的 ConnectionFactory 类型

代码：

public CachingConnectionFactory createCrewcachingConnectionFactory() {
    CachingConnectionFactory factory = new CachingConnectionFactory();
    factory.setSessionCacheSize(10);
    factory.setTargetConnectionFactory(connectionFactory1());
    return factory;
}

public ConnectionFactory connectionFactory1() {
    MQQueueConnectionFactory connectionFactory = new MQQueueConnectionFactory();
        connectionFactory.setHostName("MQ Host name");
        connectionFactory.setPort("MQ port");
        connectionFactory.setChannel("MQ Channel");
        connectionFactory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
    return connectionFactory;
}

POM 依赖关系：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>3.0.1</version>
    <relativePath></relativePath>
</parent>

<dependency>
    <groupId>org.apache.camel.springboot</groupId>
    <artifactId>camel-spring-boot</artifactId>
    <version>3.19.0</version>
</dependency>

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-core</artifactId>
    <version>3.19.0</version>
</dependency>

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-jms</artifactId>
    <version>3.19.0</version>
</dependency>

Answer 1

您将需要 JMS API。比如：

<!-- https://mvnrepository.com/artifact/javax.jms/javax.jms-api -->
<dependency>
   <groupId>javax.jms</groupId>
   <artifactId>javax.jms-api</artifactId>
   <version>2.0.1</version>
</dependency>