spring-integration

1熱度

1回答

想要提出一個更廣泛的問題，例如，如何最好地管理集羣式的Spring集成應用程序，例如典型的AWS ALB。領導人選舉：這是支持與SI與角色和領導人選舉的API https://docs.spring.io/spring-integration/reference/htmlsingle/#leadership-event-handling，我想它有良好的支持，每https://docs.sprin

0熱度

1回答

我可以在獨立應用程序中使用彈簧集成嗎？

我是新來的彈簧集成，並想知道我是否可以在獨立的應用程序中使用彈簧集成。各種服務或工作流通過發佈消息通過渠道進行通信。我想要控制應用程序的裝飾流程，並且我發現彈簧集成在這方面非常有趣。請指教。

0熱度

1回答

Spring集成設計 - 在

我想了解「最好」的方式來實現這一目標，文件處理線：使用FileReadingMessageSource作爲文件源的每一行（使用FileSplitter）增加的數據行並向其他服務器發送REST請求並等待響應。現在發送REST請求不是一個轉換，我不認爲它是一個適配器，而不是一個路由器。這是什麼？什麼是設計這個的正確方法？

0熱度

1回答

插入POJO到彈簧集成數據庫

我有一個pojo，我想插入到數據庫（Sql Server）。當我運行我的代碼時，我得到了「從UNKNOWN到UNKNOWN的轉換不受支持」。我的問題是，如果我的pojo和我的數據庫的所有命名都一樣，我可以直接寫這個（或者是否有註釋讓我這麼做）？或者我在這裏總是需要一個bean來做映射嗎？我在想這個錯誤可能是因爲我在一個不屬於它的地方干擾了它。在我的主類我有 @Inject TradePersi

0熱度

1回答

如何擴展TCP出站網關，以便在Spring集成中只接收消息

我正在開發一個支持通過Spring Integration進行TCP連接的Web應用程序。它有兩個功能。將消息發送到服務器，並在同一時間接收來自服務器的答覆剛剛收到來自服務器的消息（在服務器上的應用程序不是由Spring集成開發。）在在這種情況下，應使用TCP適配器，並且我需要提供協作TCP出站和入站通道適配器。但是，我的應用程序有一些限制。此應用程序沒有數據庫。消息的有效載荷格式

0熱度

2回答

如何使用大緩衝區設置HTTP出站網關發送請求

我使用Spring Integration 4.3.9.RELEASE和Apache HTTP組件HttpClient（4.5.2）將包含300k上傳文件的請求中繼到後端服務。有時整個配置工作正常。但有時它表現不佳，而且它將需要將近10分鐘才能發送請求並獲得迴應。我使用純Java編寫了一些測試（請參閱Sending HTTP POST Request In Java），結果如下。 +-------

1熱度

1回答

與tibco Rendezvous彈簧整合

我正在使用需要連接到Tibco RV messaging system（Not Tibco EMS）主題的獨立彈簧引導應用程序。我想知道是否有辦法將春季應用程序與Tibco RV消息系統連接起來？無論我看到的是使用Tibco EMS的例子，但無法找到任何關於在Tibco RV等對等消息系統中連接彈簧應用程序的文檔。任何形式的幫助，將不勝感激。

1熱度

1回答

Spring-Integration-DSL和Soap服務Soap頭沒有被調用

我想調用一個肥皂服務與春天集成DSL，有一些自定義頭需要添加。構建marshellingoutboundgateway。嘗試覆蓋DefaultSoapHeaderMapper，但沒有重寫的方法被調用。試圖構建這樣的事情。 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"> <soap

1熱度

1回答

Spring集成 - 跨步驟共享鎖定

我有以下設置：許多設備通過HTTP將數據發送到我的後端，其中接收器組件正在運行多個實例。我需要處理數據，然後將其發送給另一個外部合作伙伴，他們需要按時間戳順序輸入此數據。於是我想出了以下結構：有運行，在他們面前的一個負載均衡N個接收機的情況下，讓他們potientially得到所有設備的數據。這些實例通過添加一些信息來處理每個傳入數據，然後將數據放入Redis Sorted Set（每個設備都有

0熱度

1回答

如何在聚合器後定義鏈中的異常路由器

我使用Spring集成將消息聚合爲一個，然後通過FTP發送綁定適配器，我想在出站FTP服務器不可用時將聚合消息移動到特定文件夾中org.springframework.messaging.MessageDeliveryException），其他異常將通過控制檯記錄。這裏是我的配置 <int:chain id="transformChain" input-channel="inboundChann