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
最新問題