alpakka

    1热度

    1回答

    alpakka，jms中的JMS和correlationId在响应中的消息

    我已经使用alpakka（Scala）和JMS连接器在客户端和服务器之间发送/接收消息。所有工作都很完美，但我不知道 - 我如何在jms.Message中设置correlationId作为回应。任何想法，请。谢谢。
    scala akka-stream alpakka 2017-07-16

    1热度

    1回答

    Akka Streams KillSwitch在alpakka jms

    我有一个场景，我开始使用alpakka多个jmsSource（对于不同的队列）。我还需要在任何时候卸下队列。所以我已经添加KillSwitch到jms阿卡流，如下所示： - trait MessageListener { lazy val jmsPipeline = jmsSource .map { x => log.info(s"Received message ${x}
    scala akka-stream alpakka 2017-12-18

    0热度

    1回答

    为什么Akka Streams应用程序不能正常终止？

    我写了使用Alpakka卡桑德拉图书馆 package com.abhi import akka.actor.ActorSystem import akka.stream.{ActorMaterializer, ClosedShape} import akka.stream.alpakka.cassandra.scaladsl.CassandraSource import akka.st
    scala akka-stream alpakka 2017-09-12

    1热度

    1回答

    使用Alpakka显式确认JMS

    我目前使用Akka-Camel将基于Akka的应用程序与各种消息队列集成在一起。 现在我想升级到Akka的最新版本，我发现现在不推荐使用此集成。 我尝试过使用alpakka-jsm集成，但我无法查看在处理完消息后是否可以对消息队列执行明确的ack。这个功能是否存在于这个新组件中？
    jms akka akka-camel alpakka 2017-07-31

    0热度

    1回答

    Alpakka卡桑德拉流量使用

    我读Alpakka卡桑德拉here 的这使得它非常容易使用卡桑德拉作为源和汇的文档。但流量使用情况如何？ 通过流量的使用我的意思是我没有使用Cassandra作为源或接收器。但查找数据。 是否可以使用Alpakka？还是应该自己写一个流程中的Cassandra jdbc代码？
    akka-stream alpakka 2017-09-19

    0热度

    1回答

    与JMS连接Alpakka

    使用Alpakka长期订户，我们可以创建一个使用下面的代码的任何主题的非持久订阅者： Source<String, NotUsed> jmsTopicSource = JmsSource .textSource(JmsSourceSettings .create(connectionFactory) .withTopic("topic") .withB
    jms akka alpakka 2017-06-14

    2热度

    1回答

    Akka Streams，源项目作为另一个来源？

    我正在使用Alpakka-FTP，但也许我正在寻找一个通用的akka​​-stream模式。该FTP连接器可以列出文件或检索它们：理想 def ls(host: String): Source[FtpFile, NotUsed] def fromPath(host: String, path: Path): Source[ByteString, Future[IOResult]] ，我想创建
    scala ftp akka-stream akka-camel alpakka 2017-01-22
最新问题