Quarkus JMS中的ActiveMQ AMQP+ SSL

发布于 2025-01-29 23:22:25 字数 1093 浏览 5 评论 0原文

我在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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

分分钟 2025-02-05 23:22:25

您正在使用的QPID JMS客户端不支持该方案AMQP+SSL(如例外消息中所述)。 You need to use amqps instead as noted in

请记住,activemq.xml中的连接器配置(例如amqp+sslsslwss,, MQTT+SSLStomp+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 use amqps 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.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文