akka-camel

    0熱度

    1回答

    我使用一個HTTP POST方法使用URL 「https://stream.twitter.com/1.1/statuses/filter.json」,並在人體內我張貼的鍵/值我想從鳴叫 - 例如「軌道=倫敦」 。這工作正常。 現在我正在嘗試切換到AKKA-CAMEL,我正在使用他們的twitter消費者。我使用的端點URL: def endpointUri: String = s"twitter

    0熱度

    1回答

    我正在使用akka-camel訂閱rabbitmq交換。將會有幾個這樣的演員創建​​......每個請求routingKey。交換和隊列不會改變。每次請求新的routingKey我創建一個新的演員,而不是創建一個新的頻道,正在創建一個全新的連接,這是不受歡迎的。我不太明白爲什麼每次創建消費者actor時都會創建一個新連接。 這裏的演員代碼: class CommandConsumer(routin

    1熱度

    1回答

    我在Akka中使用Apache Camel,並試圖按給定的時間間隔檢查消息隊列的狀態。 我看到隊列定期記錄其狀態,但我想以編程方式能夠進行此檢查。

    1熱度

    1回答

    我目前使用Akka-Camel將基於Akka的應用程序與各種消息隊列集成在一起。 現在我想升級到Akka的最新版本,我發現現在不推薦使用此集成。 我嘗試過使用alpakka-jsm集成,但我無法查看在處理完消息後是否可以對消息隊列執行明確的ack。這個功能是否存在於這個新組件中?

    2熱度

    1回答

    我正在使用Alpakka-FTP,但也許我正在尋找一個通用的akka​​-stream模式。該FTP連接器可以列出文件或檢索它們:理想 def ls(host: String): Source[FtpFile, NotUsed] def fromPath(host: String, path: Path): Source[ByteString, Future[IOResult]] ,我想創建

    1熱度

    1回答

    在以下示例中(取自Akka Camel doc),Jetty HTTP組件用於接收HTTP消息。這是否意味着演員啓動了一個新的Jetty服務器? import akka.camel.{ CamelMessage, Consumer } class MyEndpoint extends Consumer { def endpointUri = "jetty:http://localho

    0熱度

    1回答

    我有akka camel-ftp消費者。我想處理代碼中的所有異常(例如,身份驗證異常,或無法讀取ftp上的文件)。我只能看到日誌中的堆棧跟蹤,無法處理它。 也許最好使用scalaz-camel。 此外,我想知道,當所有的文件處理和演員閒置,直到下一次讀的FTP文件夾 class FtpWorkerActor() extends Consumer with ActorLogging {

    0熱度

    1回答

    據我所知,ActiveMQ默認設置傳送模式爲PERSISTENT ...因此,在使用Akka-Camel時,如何爲特定主題設置傳送模式爲NON_PERSISTENT?以下是我的示例代碼: import akka.actor._ import akka.camel._ import org.apache.activemq.camel.component.ActiveMQComponent c

    4熱度

    1回答

    我試圖連接到ZeroMQ服務器使用apache camel。我正在使用camel-extra項目提供的camel-zeromq組件,但似乎這需要在系統上安裝本地ZeroMQ庫。 是否有人知道使用camel-zeromq組件的方法,即不需要安裝這些本機庫? 我想這幾乎是不可能的。 如果是這樣的話: 是否有可能以某種方式這些庫添加到項目中,以避免直接在系統上安裝它們? 我看到camel組件的另一個缺點

    0熱度

    1回答

    親愛的阿卡/駱駝大師們! 我具有以下路線: (netty4:TCP) - >(阿卡:演員) 我使用阿卡駝模塊,其中: 阿卡:演員是類型UntypedConsumerActor的 netty4:TCP是在阿卡的getEndopointUri方法中定義的端點:演員 netty4:tcp://localhost:8000?textline=true 當我發送字節的TCP套接字I接收例外其中電話ls該