SAP Enterprise 消息传递 - 在运行时将带有侦听器的新队列添加到现有队列

Question

我有一个围绕 SAP Enterprise 消息传递（从 S4HC 使用 BusinessEvents）的用例，以使其成为多租户。为此，该方法是为每个租户创建一个队列，并且特定队列将订阅该租户的多个业务事件。 目前，我已经使用以下代码实现了使其工作/仅侦听 1 个队列的功能。请注意，所有事件都是异步或非阻塞调用，并实现了侦听器类。

    @Bean
public Connection getSession(MessagingServiceJmsConnectionFactory connectionFactory) throws JMSException, InterruptedException {
    Connection connection = connectionFactory.createConnection();
    //connection.start();
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    Queue queue = session.createQueue(QUEUE_PREFIX + QUEUE);
    final MessageConsumer messageConsumer = session.createConsumer(queue);
    messageConsumer.setMessageListener(new DefaultMessageListener());
    connection.start();
    Thread.sleep(5000);
    return connection;

}

方法是通过服务管理器在订阅回调上创建队列，并使应用程序在不停止/重新启动应用程序的情况下侦听新队列（将其添加到现有队列中）。 如何使用 SpringBoot 获取连接工厂会话并使用侦听器添加新队列以使其动态化？ 你能在这方面提供帮助吗？

Answer 1

这段代码看起来不像SAP Cloud SDK。我们检查了两次，在我们的代码中找不到提到的类。我们为企业消息传递提供 PoC 支持，但不推荐使用它，而是支持通过云应用程序编程模型 (CAP) 为它计划发布的库

查看 CAP 在 Java 中的 Event Handlers 部分了解更多详细信息。据我所知，feature overview table CAP 尚不支持 Java 库的多租户。从这个意义上说，Node.js 的实现已经完成。

在 SDK 中，我们计划在 CAP 实施完成后提供一些便利。他们的实现

我认为您可以通过他们的support channels 联系 CAP。