apache-camel

0熱度

3回答

我正在使用Spring Boot，並且我剛剛添加了駱駝。我有一個簡單的駱駝路線設置： import org.apache.camel.builder.RouteBuilder; import org.springframework.stereotype.Component; @Component public class MyRoute extends RouteBuilder {

0熱度

1回答

Apache駱駝讀取目錄並獲取文件內容

我想讀取具有特定文件路徑的目錄並使用apache駱駝和spring啓動獲取文件內容。我有Java中的路由器和處理器類。互聯網上的資源並不多，但只能在apache駱駝的官方網站上。先謝謝你。

0熱度

1回答

Apache Camel .when（）聲明只適用於一半的時間

我有一個.choice（）語句與多個.when（）情況。但是，每次上傳MsgFmtVerNr = 2時都會上傳相同的文件，有時會上傳到相同的文件，有時它會經過.when（）。xpath（「/ UpsBas/MsgHdr/MsgFmtVerNr ='2'」）。我不知道爲什麼這個聲明只有一半的時間。是否有一些原因直接跳轉到.otherwise（）語句？感謝您的高級幫助。 .choice()

-1熱度

2回答

Apache的駱駝正則表達式格式爲txt文件

我想用正則表達式模式爲apache駱駝txt文件，但問題是正確的模式，以及如何在from()方法中使用它。該文檔僅提及關鍵字包含和排除。爲了檢查文件名是否匹配正則表達式模式，使用模式最簡單的方法是什麼？先謝謝你。

0熱度

1回答

駱駝和ActiveMQ的：無法解析端點

，我發現了以下錯誤在應用中的用戶Apache的駱駝和ActiveMQ的：無法解析端點：iasJms：// setStatus由於：無組件發現方案：iasJm 這是造成問題的路線聲明： rest("/setStatus") .put("/{number}") .route() .from("direct:setStatusRest") .setE

1熱度

1回答

駱駝單元測試用例問題

我有一個文件傳輸路由。在這之間，我必須插入審計表並記錄一些最基本的信息。路線工作正常，但我無法做駱駝單元測試。 public class EobRequestTest extends CamelBlueprintTestSupport { @Test public void testRoute() throws Exception { MockEndpoint moc

0熱度

1回答

租戶解析器的camelContext屬性鑑別器，使用jpa multitenant和camel routeId

我問你如何使用camelContext來獲取由事件觸發的路由名稱，更詳細地說，我如何在camelContext中使用任何種鑑別器屬性x謂詞決定（如果x = 1，那麼其他.. ..）例如：我有這樣的路線： //this route use the forst database from("direct:csvprocessor1") .routeId("tenant1")

0熱度

2回答

駱駝路由外部REST Web服務

我正在使用Spring MVC並使用Apache駱駝來集成外部服務。我想使用Apache Camel路由來進行Web服務調用。就像我的本地REST服務（http://localhostsmiliex.xx:8080/users）從外部REST服務（http://xxx:000/users）獲取數據並希望路由獲取外部數據。哪個Apache組件適用於Web服務路由，如Jetty或生產者模板？

1熱度

1回答

如何用camel-kafka手動控制偏移提交？

我使用的是駱駝卡夫卡組件，我不清楚引擎蓋下發生的錯誤。如下所示，我正在彙總記錄，我認爲對於我的用例來說，只有在記錄保存到SFTP後提交偏移纔有意義。是否可以手動控制何時可以執行提交？ private static class MyRouteBuilder extends RouteBuilder { @Override public void configure() thr

-1熱度

1回答

如何正確解決Tika在Fuse（camel）包中的傳遞依賴關係？

我正試圖在Fuse（6.3）項目中實現Tika功能。在最新的當前版本1.16中，Tika爲解析器提供了Osgi捆綁包。我無法通過適當的osgi方式將Tika納入我的項目。任何提示如何創建依賴配置並使用osgi包？