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駱駝RabbitMQ每次創建新連接

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

1熱度

1回答

檢查Apache Camel中消息隊列連接的狀態

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

1熱度

1回答

使用Alpakka顯式確認JMS

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

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]] ，我想創建

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回答

Akka Camel和ActiveMQ：如何設置傳送模式

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

4熱度

1回答

Apache駝峯：連接到ZeroMQ服務器

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

0熱度

1回答

camel-akka和演員的迴應

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