apache-camel

0熱度

1回答

發送數據到Wildfly 10嵌入的Artemis實例並接收它們使用Apache Camel

我試圖發送一些數據到Wildfly 10 Artemis實例並使用Apache Camel接收它們。在這裏，我知道，這可以使用camel-jms組件完成。在這種情況下，我首先創建了一個簡單的示例來檢查這是否工作正常。但是，它在ConnectionFactory創建點處給出了以下例外。 Exception in thread "main" javax.naming.NamingExceptio

0熱度

2回答

動態Apache駱駝輸出路由

嗨，我想要使用apache駱駝計算動態輸出路由。我在文件夾位置收到一堆文件，根據其內容我想將文件移動到動態輸出文件夾。輸出文件夾的名稱將根據文件的輸入內容構建。我如何實現它。下面這段代碼讀取文件，處理它們，但我不知道如何設置的$ {文件夾名}基於文件的內容價值 from("file:D:\\camel\\input\\one?recursive=true&delete=true")

0熱度

1回答

限制Camel CometD端點的協議

是否可以限制Camel CometD端點或一般端點允許使用哪些協議？例如，我想限制端點，以便它只能通過websockets接收呼叫，而不允許HTTP。

0熱度

1回答

如何顯示駝峯發生節流

我想知道是否有辦法執行諸如System.out.println();之類的操作或記錄發生了節流。目前我可以看到發生限制的唯一方法是將rejectExecution設置爲True。問題是，如果它設置爲true，那麼請求不會在發生限制時被處理。有沒有辦法通知使用駱駝發生了限制？

0熱度

1回答

Apache Camel只讀第一行

我有一個要求，我必須根據其內容動態地在目錄上推文件。與該目錄相關的信息可在文件的第一行中找到。由於文件的大小很大，加載文件的全部內容將不合適。另外我想在讀取第一行時跳過文件的其餘部分。以下是我寫 from("file:D:\\camel\\input?recursive=true&delete=true") .split().tokenize("'",1) .pr

0熱度

2回答

下載集從FTP與駱駝的文件通過REST調用

我想通過REST調用使用駱駝的路線從FTP下載文件集：我想以下幾點： from("cxfrs:bean:restndpoint") .pollEnrich("some ftp url") .to("destinationFilesLocation") .bean(MyBean.class); 它僅適用於一個文件在ftp上，當我試圖運行它再一次它只是等待文件。如果我用（「某些ftp url」替換p

1熱度

1回答

如何測試在Apache的駱駝（春季）路線

這是我的system.xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.

0熱度

2回答

駱駝動態路由不轉發郵件

我正在基於webservice和jms隊列的駱駝動態路由管理器。我有這個以下結構： endpoint:cxf -> jms:queue -> dynamic routing to a jms:queue -> processing 這裏是我的路由定義： @Override public void configure() throws Exception { routeDefinit

0熱度

1回答

log4j：WARN無法找到記錄器的appender（org.apache.camel.impl.DefaultCamelContext）

我開發了一個Java Camel項目，將文件從resources/data/inbox移動到SFTP服務器。當我運行它，我得到這個消息： /usr/lib/jvm/jdk1.8.0_144/bin/java ...的log4j：警告沒有附加目的地可能是發現記錄器（ORG .apache.camel.impl.DefaultCamelContext）。 log4j：WARN請正確初始化log4j

0熱度

2回答

組合[彈簧] DefaultShutdownStrategy的，[駱駝] ShutdownAware和[駱駝處理器不工作

我有駱駝Processor其開始Thread 此Processor實現彈簧ShutdownAware 當我發送TERM信號（正常關閉）到應用我沒有收到任何有關以下信息 - 從ShutdownAware接口被調用的任何方法。我提到過關於Thread，因爲我想正確地阻止它。 import org.apache.camel.Processor; import org.apache.camel.spi