spring-integration

2熱度

1回答

我有一個http網關調用，偶爾會返回503錯誤。我想在該呼叫周圍配置retry advice，但我不想爲每個錯誤都做這個，只是503s。 <int-http:outbound-gateway ... errorHandler="..."> <int-http:request-handler-advice-chain> <int:retry-advice max-attempt

0熱度

1回答

SFTP持久性接受只在sftp網關過濾一次

我有這個代碼中我想合併一個SftpPersistentAcceptOnceFileListFilter，我不知道如何。過濾器應在本地檢索文件之前進行。 @InboundChannelAdapter(value = "sftpMgetInputChannel", poller = @Poller(fixedDelay = "5000")) public String filesForMG

1熱度

1回答

Spring集成DSL：與FileSplitter開始/結束標記有效載荷處理

我想設置這樣的集成信息流： return IntegrationFlows .from("inputChannel") .split(fileSplitter) .handle(this::doStuff1) .handle(this::doStuff2) .handle(this::doStuff3) .aggr

2熱度

1回答

縮放Spring集成Web應用

有此無狀態REST應用/ API通過我使用Spring集成API編寫和正在維持與工作手在手以下基本概念： 1）入站HTTP網關爲RESTful入口點 2）幾個服務激活器，路由器，通道和變換器 3）一個分割器（和一個聚合器）與前者訂閱了一個通道，該通道又有一個任務執行器接線，包括一個大小爲線程池100用於並行執行拆分（特德）消息該應用程序目前無縫運行 - 作爲下一個步驟中，我的嘗試是擴展此應用程序

1熱度

1回答

彈簧集成中的Windows密鑰驗證

我有一臺Windows服務器，我需要將文件傳輸到另一臺服務器，其中sftp。目標服務器可能是Linux或Windows系統。我的問題是，我必須依賴我的Windows機器上的第三方sftp服務器軟件還是春天集成照顧呢？我應該如何在Windows上生成公鑰和私鑰對？

1熱度

1回答

與觀察服務和LastModifiedFileListFilter的彈簧集成文件輪詢

我想知道是否有人會知道我是否可以在FileInboundChannelAdapter中使用Watch服務以及LastModifiedFileListFilter？下面的示例代碼給了我相當不一致的結果。有時文件只是在文件夾中，並且保持未處理狀態。我懷疑監視服務可能與LastModifiedFileListFilter不兼容。對於例如如果LastModifiedFileListfilter設置爲

0熱度

1回答

Spring集成頭

我在Spring集成實現了一個簡單的TCP連接工廠： @Bean @ServiceActivator(inputChannel = "toTcpChannel") public TcpSendingMessageHandler tcpOutClient() throws Exception { TcpSendingMessageHandler sender = new TcpSend

1熱度

1回答

與MongoDbMessageStore的Spring集成聚合器：無法實例化GenericMessage：沒有找到默認構造函數

我使用Spring Integration 4.3.11與Spring Data MongoDB 1.10.6。我有一個消息聚合器，使用MongoDbMessageStore。當從消息序列的消息進來，它堅持在MongoDB中，但緊接着（在o.s.i.store.AbstractMessageGroupStore#addMessageToGroup）當從MongoDB中讀取 Failed to in

1熱度

1回答

使用Spring Integration批量插入JDBC

我是Spring Integration的新手。我遵循幾個文件，並使我的SI jdbc工作。現在我正試圖查看我們是否可以用SI jdbc同時執行多個插入操作。要實現單個插入，我做了以下內容：接口與我的數據的方法有參數對象 SI XML與一個。頻道 b。網關（接口詳細信息） c。出站網關 - 數據庫和查詢詳情 d。豆與鍵和值對有效載荷映射任何人都可以解釋如何做一個SI jdbc的基本批量插入

2熱度

1回答

Spring集成 - MongoDB的入站通道讀取

我需要使用Spring集成查詢到MongoDB的數據，我可以能夠查詢從MongoDB的，但同樣的數據數據返回不止一次相同的數據， <bean id="mongoDBFactory" class="org.springframework.data.mongodb.core.SimpleMongoDbFactory"> <constructor-arg name="mongo"