我尝试通过 amqp 协议使用来自 ActiveMQ 服务器的消息。由于 ActiveMQ 以及从 javax.jms 到 jakarta.jms 的切换以及与 Spring-Boot v3 版本的分离,我想出了以下设置:
//plugin
id 'org.springframework.boot' version '3.0.6'
//dependencies
implementation group: 'org.springframework', name: 'spring-jms', version: '6.0.8'
implementation group: 'org.apache.activemq', name: 'activemq-client-jakarta', version: '5.18.1'
我为所需的
ActiveMQConnectionFactory
创建了一个 jakarta.jms.ConnectionFactory
bean,这似乎工作正常。
话虽如此,我的实际问题是,我遇到了传输协议问题。我发现当我导入
implementation group: 'org.apache.activemq', name: 'activemq-amqp', version: '5.18.1'
我可以使用 amqp 协议消费消息。但我仍然缺少的是 amqps 的传输协议,因为我想要使用的实际 url 提供了对 amqps 的访问。所以我其实有两个问题:
提前感谢您的任何建议和解释。