jms - SharedConsomer 与 quarkus，可能吗？

Question

我想知道是否可以将共享消费者与 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");

如何设置订阅者？

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

Answer 1

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

如果您想请求更改 SmallRye Reactive Messaging 项目（包括 JMS 连接器），那么您可以在他们的GitHub 项目中这样做。