Quarkus 应用程序可以连接到多个 JMS 代理实例吗？

Question

有没有办法从 Quarkus 应用程序使用 JMS 连接到 ActiveMQ Artemis 的多个实例？

我在 the documentation 中看到，对于 [Qpid JMS - AMQP] 和 [Artemis JMS]，属性中的连接 URL 是一个字符串，它是必需的。这是否意味着我无法指定要连接的多个代理 URL？

我不想使用 camel-quarkus-activemq 或 camel-quarkus-jms 因为 this current bug。

Answer 1

就像@Robbie Gemmell 在评论中指出的那样。

一个 ConnectionFactory 采用所需参数的代理 URL。那么对于另外一个ConnectionFactory我们直接实例化即可。像这样：

application.properties

# Configures the Artemis properties.
quarkus.artemis.url=tcp://localhost:61616
quarkus.artemis.username=admin
quarkus.artemis.password=admin

# Broker URL for the second ConnectionFactory
brokerURLService=tcp://remote-service:61616

骆驼配置

@ApplicationScoped
public class CamelConfigurationz {

  @Value("${brokerURLService}")
  private String brokerURLService;

  @Named
  public Sjms2Component sjms2(ConnectionFactory connectionFactory) {
    Sjms2Component sjms2 = new Sjms2Component();
    sjms2.setConnectionFactory(connectionFactory);
    return sjms2;
  }

  @Named
  public Sjms2Component sjms2Service(ConnectionFactory amqJmsServiceFactory) {
    Sjms2Component sjms2Service = new Sjms2Component();
    sjms2Service.setConnectionFactory(amqJmsServiceFactory);
    return sjms2Service;
  }

  @Named
  public ActiveMQJMSConnectionFactory amqJmsServiceFactory() throws JMSException {
    ActiveMQJMSConnectionFactory amqJmsServiceFactory = new ActiveMQJMSConnectionFactory();
    amqJmsServiceFactory.setBrokerURL(brokerURLService);
    return amqJmsServiceFactory;
  }

}

路线

public class CamelRoutes extends EndpointRouteBuilder {

  @Override
  public void configure() throws Exception {

    from(sjms2("inquarkus"))
    .log("got activemq message ---------------------------------")
    .to(sjms2("outquarkus"));
    
    from(sjms2("sjms2Service", "inquarkusService"))
    .log("got activemq message service ---------------------------------")
    .to(sjms2("sjms2Service", "outquarkusService"));

  }

}

它可以以不同的方式完成，因此请注意，我在上面的示例中也使用了 spring di 扩展来使用 @Value。还 camel-quarkus-endpointdsl 使用 EndpointRouteBuilder。

Quarkus 应用程序可以连接到多个 JMS 代理实例吗？

Can Quarkus app connect to multiple JMS broker instances?

activemq-artemis

quarkus