我正在尝试通过 Akka Streams 连接到通用消息队列(由 Software AG)。我查看了 Akka Streams 的文档关于 Camel 集成,但我正在努力理解码件如何组合在一起。例如,我必须使用 ActiveMQ 作为代理吗?
我之前已经通过 MQTT(和 Spark 的 MQTTUtils)建立了一个连接,但是因为我想尝试 Akka,所以我认为不需要通过 TCP 的 MQTT。 [推荐}( http://tech.forums.softwareag.com/techjforum/posts/list/55887.page ) 我使用 JMS 而不是其他协议(protocol),尤其是使用第三方工具时。因此,我提出了关于通过 JMS 将 Akka Streams 正确设置为 UM 的问题。
最佳答案
建议是远离 Camel 并利用完全响应式(Reactive)、基于 akka-streams 的解决方案。 Alpakka 项目的诞生是为了在一个捆绑包中收集与 akka-streams 兼容的连接器。
它当前包含一个 JMS 连接器(以及 AMQP 和 MQTT 连接器)。更多信息:
关于scala - 将 Akka 流连接到 JMS,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40240257/