spring-integration

0熱度

1回答

我想用建議在出站適配器中做一些重試邏輯，比如說ftp出站適配器，但是當我學習「Spring集成參考手冊」時，我發現通知只能用在答覆產生端點，這是真的嗎？如果我的理解是正確的，在出站適配器失敗後如何重試？感謝

1熱度

1回答

這是一個後續行動這樣一個問題： Spring Integration Aggregator failing - "No reply received within timeout" message being displayed 在繼續測試在WebSphere 8.5我的POC，問題重新浮出水面，其中本從天而降錯誤： GenericMessagW¯¯org.springframework.mess

1熱度

1回答

在使用彈簧集成創建的Socket上設置哪些超時？

我有兩個bean創建客戶端套接字連接到服務器：AbstractClientConnectionFactory和TcpOutboundGateway。服務器提供1分鐘的超時時間。問題：哪些超時是否必須在bean上設置，以便spring/java在服務器超時之前不終止連接？的以下屬性： factory.setSoTimeout(); gateway.setRequestTimeout();

0熱度

1回答

Spring集成：Scatter-Gather模式實現

我正在開發一個Spring Integration的文件解析系統。該場景是下一個：輪詢器從目錄中提取文件，然後我們應用一些轉換，解析等......最後，我們需要將數據存儲到兩個源（mongoDB和文件系統）中，並刪除原始文件。我正在使用Scatter-Gather模式並行執行存儲操作。問題：如何自動釋放組？並將彙總的結果傳遞給最終處理程序？下面是一個代碼示例： @Bean public

1熱度

1回答

Spring集成HTTPOutboundGateway ::連接池和connectionTimeout，soTimeout，maxTotalConnections

我們是將基於騾子應用到春天，在我們使用的騾子HttpsConnector消費第三方服務的現有代碼的過程中，我們希望做的一樣使用Spring的Http出站網關.. org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler 這裏的事情，我的問題是，如何啓用HTTP連接池？如何設置的道具像conn

0熱度

1回答

春季整合。通過分離器傳播一些頭文件

我有一個如下的消息處理鏈。 <int:header-enricher input-channel="acceptFileChannel" output-channel="validateMessageChannel"> <int:error-channel ref="validateSplitTransformErrorChannel"/> <int:header name="

0熱度

1回答

如何解決「不支持的消息負載類型」

我是被卡住的...應用程序從某個目錄讀取* .json文件，將它們轉換爲MyObject類對象。如果類的類型爲「PEN」，它將保存爲對象。對象類型是枚舉： public enum ObjType { FOOD, PEN, DRINK } 我隔壁班： public static void main(String[] args) throws Exception{ Spri

1熱度

3回答

集成模式：如何同步從多個系統接收到的處理消息

我正在構建一個系統，該系統將通過來自不同系統的消息代理（當前爲JMS）接收消息。來自所有發件人系統的所有消息都有一個設備ID，並且在接收消息時沒有任何順序。例如，系統A可以發送deviceId = 1的消息，系統b可以發送deviceId = 2的消息。我的目標不是開始處理有關同一deviceId的消息，除非我從具有相同deviceId的所有發件人收到所有消息。例如，如果我有3個系統A，B和

2熱度

1回答

TCP服務器在python發送文件到TCP客戶端與Spring集成

我需要實現一個TCP客戶端與Spring集成，使用註釋，沒有XML配置。 TCP服務器必須發送文件，我必須使用Spring集成來處理它們，並打印它們（現在）。所以，我用python製作一個TCP服務器，但是對此沒有任何重要性。代碼： import socket as s host = '' port = 2303 co = s.socket(s.AF_INET, s.SOCK_STREA

1熱度

1回答

消息不會出現在Spring集成（卡夫卡）ErrorChannel當代理不可用

我使用Spring集成基於簡單卡夫卡項目工作，我們要求當代理下來，消息便傳進了ErrorChannel，我們可以對付他們/另存爲「死文字」等我們越來越是例外的無數運行： 2017-09-19 17:14:19.651 DEBUG 12171 --- [ad | producer-1] o.apache.kafka.common.network.Selector : Connection with