spring-dsl

2熱度

1回答

我想將流程的特定部分作爲事務處理。例如，我想在前兩個變換操作中使用一個事務性塊。下面是我用的流量代碼： @Bean public IntegrationFlow createNumberRange() { return IntegrationFlows.from("npEventPubSubChannel") .transform(...) .trans

0熱度

1回答

如何從報頭值在Apache的駱駝設置隊列名稱

我試着從報頭值設置ActiveMQ的隊列名稱，但其不低於發生的事情是我春DSL <setHeader headerName="x-so-queue-name" id="_setHeader1"> <xpath resultType="java.lang.String">/Message/@IntObjectName</xpath> </setHeader> <log id="_lo

1熱度

1回答

創建sftp回覆通道，回覆錯誤或發送失敗的消息

我正在使用java dsl配置sfp出站流。網關： @MessagingGateway public interface SftpGateway { @Gateway(requestChannel = "sftp-channel") void sendFiles(List<Message> messages); } 配置： @Bean public IntegrationFlow

1熱度

1回答

如何使用DSL跳過springcloudstream文件的標題行（第一行）？

我正在使用Spring雲流來讀取文件並使用文件分割器進行分割，並使用DSL樣式將每行作爲消息發出，正在讀取的文件有一個標題行，只是想知道是否有一種簡單的方法可以跳過標題行讀/讀之前/之後。任何幫助表示讚賞。這裏是我的分配器和integrationFlow的樣子： enter code here return IntegrationFlows .from("....")

0熱度

1回答

問題與駱駝定製@Converter使用春季DSL

我只想學習自定義轉換器並遇到問題。任何幫助深表感謝。駱駝版本2.17和JBoss保險絲6.3 @Converter public class MyConvertor{ public MyConvertor(){} @Converter public static String convertTo(Exchange exchange) {} } 在我的春天

1熱度

2回答

爲鏈中的每個處理程序分配不同的錯誤處理程序

我有一個應用程序指定一個簡單的流，其中需要按特定順序調用一系列服務來執行某些功能。 Spring集成和它的DSL似乎適用於這種情況。這些個別服務中的任何一個都可能失敗（這些服務是對外部應用程序的調用），此時鏈應該停止。不僅如此，控制流也需要重定向到其他地方，具體取決於失敗的服務。換句話說，我需要爲每個服務提供不同的錯誤處理程序。問題是我很難找到如何做到這一點，如果有人能指出我正確的方向，我將非

0熱度

1回答

駱駝分配器商店CamelSplitSize，失敗

http://camel.apache.org/splitter.html [1] 從[1]鏈路只見CamelSplitSize將在已完成的交易處理的行。我學習駱駝，我想知道的是有可能的方式來分割包含100行的xml文件（假設100行）如果分割在處理第50行的失敗，我們需要顯示CamelSplitIndex 50，CamelSplitSize 100和CamelSplitComplete假 .

0熱度

1回答

ActiveMQ內的路由邏輯到特定的工作池

我有一個場景，我有相同的隊列配置爲SMS和EMAILS。我希望ActiveMQ將消息路由到特定的使用者池，即如果它是SMS，則必須將其路由到工作線程池以用於SMS。所以，如果我需要擴大SMS的數量，那麼我只需要增加SMS Worker Pool的池大小而不是EMAIL工作池。我可以使用Apache Camel來實現我的需求的路由邏輯嗎？

0熱度

1回答

spring-integration-dsl：使Feed-Flow工作

我正在嘗試使用一組已配置的RSS-feeds對RSS閱讀器進行編碼。我認爲一個好方法就是通過編碼原型來解決這個問題 - @Bean並用配置中找到的每個RSS提要調用它。但是，我想我在應用程序啓動時忽略了一點，但沒有任何反應。我的意思是豆創建爲我所期待，但沒有記錄在handle() - 方法發生： @Component public class HomeServerRunner implemen

-1熱度

2回答

如何使用任意地圖（動態對象）創建DSL Groovy配置文件

如何將任意Groovy地圖/列表轉換爲Groovy提供的配置樣式DSL語法？例子： def config = [ 'test': 'lalala', 'nestedObject': [ foo1: 'foo1 val', foo2: 'foo2 val', nested2: [ anInt: 5, anArray