scala - 将 Akka 流连接到 JMS

标签 scala jms akka-stream webmethods

我正在尝试通过 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 连接器)。更多信息:

  • 正式上线article
  • Alpakka home
  • JMS connector docs
  • 关于scala - 将 Akka 流连接到 JMS,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40240257/

    相关文章:

    scala - 缺少大小.unapply

    scala - 如何用 Akka-Http 一般包装拒绝

    Scala 内联 unapply 提取器

    scala - "can' t 存在性抽象参数化类型..."

    java - 重播实时收集的数据以模拟真实的流量延迟和消息排序

    java - 如何在没有 Jms session 对象的情况下复制 javax.jms.TextMessage

    java - 在运行时更新 jms 入站适配器目标

    java - JMS 主题与队列 - 意图

    scala - Akka-stream:在mapAsync完成数据处理之前调用onComplete

    scala - 将 TCP 服务器的输出捕获到 Akka Stream 队列的最推荐方法是什么?