Quarkus JMS中的ActiveMQ AMQP+ SSL
我在Quarkus应用中使用ActiveMQ经纪人有问题。首先用法,我想尝试官方网站,我的一切都完全像示例(<<代码> PriceConsumer ,PriceProducer
,资源
,quarkus-qpid-jms
依赖关系和quarkus.qpid-jms /code> - 用户名/密码),除
quarkus.qpid-jms.url
外使用 AMQP+SSL 协议。
当我尝试使用此端点运行应用程序时,它会返回错误:
"loggerName":"org.apache.qpid.jms.provider.ProviderFactory",
"level":"ERROR",
"message":"Failed to create Provider instance for amqp+ssl, due to: {}",
"threadName":"FailoverProvider: async work thread",
(...)
"exception":{"refId":1,"exceptionType":"java.io.IOException","message":"Provider scheme NOT recognized: [amqp+ssl]"
如何为Quarkus中的AMQP+SSL配置该示例? 听起来很容易,但是我什么都找不到(我是经纪人主题的真正初学者)。 我必须使用ActiveMQ的所有协议: amqp+ssl < / strong> / ssl < / strong> / wss < / strong> / / mqtt+ssl < / strong> / stl < / strong> / <强>踩踏+SSL
I have a problem with use my ActiveMQ broker in Quarkus app. To first usage I wanna try example from the official website, and I have everything exactly like in examples (PriceConsumer
, PriceProducer
, Resource
, quarkus-qpid-jms
dependency, and quarkus.qpid-jms
- username/password), except quarkus.qpid-jms.url
, because there are endpoints with amqp, but I can't use that, I have endpoints with amqp+ssl protocols.
When I've tried run application with this endpoints, it return errors:
"loggerName":"org.apache.qpid.jms.provider.ProviderFactory",
"level":"ERROR",
"message":"Failed to create Provider instance for amqp+ssl, due to: {}",
"threadName":"FailoverProvider: async work thread",
(...)
"exception":{"refId":1,"exceptionType":"java.io.IOException","message":"Provider scheme NOT recognized: [amqp+ssl]"
How could I configure that example for amqp+ssl in Quarkus?
It sounds easy, but I couldn't find anything about that (and I'm a really beginner in brokers topic).
All protocols which I have to my ActiveMQ: amqp+ssl / ssl / wss / mqtt+ssl / stomp+ssl
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
您正在使用的QPID JMS客户端不支持该方案
AMQP+SSL
(如例外消息中所述)。 You need to useamqps
instead as noted in请记住,
activemq.xml
中的连接器配置(例如amqp+ssl
,ssl
,wss
,,MQTT+SSL
,Stomp+SSL
)适用于 Broker 。每个客户端实现都有自己的独特连接支持,无论是通过URL还是其他内容。您不能在客户端上使用经纪人的配置,并期望它可以正常工作。The Qpid JMS client you're using doesn't support the scheme
amqp+ssl
(as noted in the exception's message). You need to useamqps
instead as noted in the documentation.Keep in mind that the connector configuration in your
activemq.xml
(e.g.amqp+ssl
,ssl
,wss
,mqtt+ssl
,stomp+ssl
) is for the broker only. Each client implementation has its own unique connection support whether than be via a URL or something else. You can't use the broker's configuration on a client and expect it to work.