apache-camel

0熱度

1回答

我使用http4組件並將msg多播到多個路由。每條路線都在呼叫Rest服務。基於http響應代碼，我想處理異常。我得到了所有400,500響應代碼的httpOperationFailedException，但是對於404情況，我想繼續路由，對於其他情況，執行應該停止。我怎樣才能做到這一點？謝謝。

0熱度

2回答

JMS組件 - ConnectException for InOut模式

我在使用Apache Commons JMS組件時遇到了問題。如果我使用InOut交換模式將消息放入隊列並且JMS服務器關閉，則會收到java.net.ConnectException，並且每5000毫秒會發起一次恢復嘗試。我假設駱駝隱式創建一個消費者端點來偵聽replyTo隊列，所以我不確定是否可以禁用這個行爲。有沒有辦法在這種情況下禁用恢復？

0熱度

1回答

使用db中的文件名讀取文件內容駱駝

我必須在db中執行查詢以從表中獲取文件名。然後我必須使用從查詢中獲得的文件名讀取文件夾/目錄中的文件內容。我已經完成了查詢部分並使用一個bean在Exchange中存儲了文件名列表。但我想知道如何使用這個文件名作爲交換來讀取文件內容。能否請你幫忙？

0熱度

1回答

駱駝移動它後刪除文件的內容

我有一個駱駝的春季啓動應用程序，我嘗試從服務器使用FTP將文件移動到我的本地計算機，我的問題是移動它後文件爲空，這是我的類，它擴展了RouteBuilder類： public class Controlador extends RouteBuilder{ @Autowired private ArchivoBS archivoBS; @Override

0熱度

1回答

駱駝csv創建問題

我需要創建一個csv文件，其中包含使用Camel的以下結構。 school1_id，school1_name class1_id，class1_name，division1 student1_id，studennt1_firstname，student1_lastname student2_id，studennt2_firstname，student2_lastname class2_id，cla

0熱度

1回答

在pojo中的producer.sendBodyAndHeader上設置AMQ標頭

我使用activemq-camel-5.12.0和camel 2.15.2從POJO發送消息。偉大的作品使用sendBodyAndHeader（endpointString，味精，headerName，headerValue），但是當我嘗試使用sendBodyAndHeader（endpointString，味精，地圖）來發送消息，並設置多個標頭，我得到以下異常： java.lang.Illega

1熱度

1回答

Apache Camel FTP客戶端併發

我遇到了問題。我有我在兩個不同的服務器上部署的兩倍的應用程序，該應用程序使用ftp組分： <from uri="ftp://..." /> 正如我部署兩次（Like this）我有併發性和一些FTP服務器中的文件正在處理兩次，或者在其他節點首先處理異常時引發異常（FileNotFoundException）。有沒有解決方案？ Thx。

0熱度

1回答

休息駱駝傳遞終點

概述之間的對象。我的駱駝設置調用兩種服務方法。第一個響應被傳遞到第二個響應，然後輸出最終響應爲json網頁。相當簡單沒有太複雜。進一步細分提供一些更多的上下文。 Method_1。採用scanId。這工作正常。它產生一個名爲ScheduledScan.class Method_2的對象。引入ScheduledScan .class的先前實例並返回ConvertedScans掃描列表。然後想顯示

0熱度

2回答

如何管理在春季啓動交易

我有一個春季啓動應用程序和使用駱駝與它，我讀了一個文件，然後我嘗試插入我的數據庫，一切都運行良好唯一的問題是，我嘗試使用@transactional或transactionTemplate使回滾時發生錯誤，但它不會使回滾，隨着@transactional我添加到我的SpringBootApplication和@EnableTransactionManagement(proxyTargetClas

0熱度

2回答

CamelContext沒有采用Spring註釋的路線

我剛開始在我的一個項目中使用Camel。我試圖用Spring配置Camel，但遇到問題。我不想使用xml配置，而是使用基於Spring的Annotations來配置路由和處理器。我的應用程序是一個獨立的Spring應用程序，它將作爲Jar運行。爲了保持應用程序的運行，我有一個空的預定方法，每運行x分鐘。下面是我build.gralde // Spring // compile('org.