SharedConsomer 与 quarkus，可能吗？答案

【问题标题】：SharedConsomer with quarkus, possible?SharedConsomer 与 quarkus，可能吗？
【发布时间】：2021-08-25 15:31:44
【问题描述】：

我想知道是否可以将共享消费者与 Quarkus 的 JMS 连接器一起使用。我想做这样的事情：

final TopicConnection topicConnection = factory.createTopicConnection();
final TopicSession topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
final MessageConsumer subscriber = topicSession.createSharedConsumer(new MQTopic("mytopic"), "mysubscription");

如何设置订阅者？

在连接器中添加“共享”属性是否值得？

【问题讨论】：

我不太明白你的问题。为什么不能使用 Quarkus 的 JMS 连接器来做到这一点？ “设置订阅者”是什么意思？请详细说明您尝试了什么以及为什么它没有奏效。谢谢！
我尝试使用 SharedConsumer jms 2.0 功能，如下所述：oracle.com/technical-resources/articles/java/jms2messaging.html。 quarkus jms-connector 怎么办？
为什么不像Quarkus JMS documentation 中描述的那样简单地注入您的ConnectionFactory 并照常使用JMS 2.0 API？
谢谢你，我确实能够让它像那样工作。但最好为 quarkus 反应式 jms-connector 提出一个“共享”属性

标签： jms quarkus smallrye

【解决方案1】：

您可以按照Quarkus JMS documentation 中的说明注入您的ConnectionFactory，并照常使用JMS 2.0 API 来创建您的共享订阅者。

如果您想请求更改 SmallRye Reactive Messaging 项目（包括 JMS 连接器），您可以通过他们的GitHub project 进行更改。

【讨论】：