spring-integration

0熱度

2回答

我想輪詢排隊中不超過30分鐘的消息。我該如何做到這一點與jms：消息驅動通道適配器？請幫忙。

0熱度

1回答

有沒有一種方法來配置Spring集成通道，以便在發生未捕獲的異常時，將異常時的頭文件（如果可用）發佈到errorChannel以及異常對象？現在，我可以訂閱'errorChannel'，並在那裏添加處理代碼非常有用。但在errorChannel中，我只能得到異常;來自原始頻道的標題將丟失。我試着看看這裏的參考（https://docs.spring.io/spring-integration/r

0熱度

2回答

使用Spring集成一次發送帶有消息負載的單個json對象字符串？

我正在使用spring集成來使用JdbcPollingChannelAdapter輪詢數據庫，然後使用JmsSendingMessageHandler將結果發佈到Activemq隊列中。我使用MappingJackson2MessageConverter將jdbc結果序列化爲json字符串。收到消息後，它將作爲數組列表發送。是否有可能一次只發送一個消息的有效載荷的單個json-serialized

2熱度

2回答

自定義註釋不會在Spring bean工作

我創建了我新的自定義註釋@MyCustomAnnotation @Target({ElementType.METHOD, ElementType.TYPE, ElementType.FIELD}) @Retention(RUNTIME) public @interface MyCustomAnnotation{ } 我申請的組件和bean中的註釋。下面是代碼， @MyCustomAnno

0熱度

2回答

@EnableIntegration禁用@Cacheable

我開發一個Spring 5.0.0 RC3基於MVC的Web許多倉庫使用@Cacheable出於性能方面的應用： package com.example; @Configuration @EnableTransactionManagement @EnableScheduling @EnableCaching(order = Ordered.LOWEST_PRECEDENCE) @Ena

0熱度

1回答

maprsteam with spring integration java client

我正在尋找一個解決方案，使用maprstream與彈簧整合。我可以創建流和主題，也可以使用流：主題組合來消費/發佈消息。通過參考link來使用卡夫卡客戶端：但是使用Spring集成努力消費/發佈消息，並且看不到任何解釋相同的示例程序。有人可以幫助我嗎？

0熱度

1回答

彈簧集成的請求/響應套接字

我有一個彈簧引導服務器應用程序，我需要創建一個ssl套接字並讓客戶端連接到它。我希望能夠向客戶端發送一條消息（例如，在向我的服務器發送REST API請求時），並且還讀取它發回的響應。我設法到目前爲止做的是：創建套接字，並允許客戶端連接（從TcpEvent保存連接ID）根據要求發送插座上的消息客戶端接收請求併發送回一個響應在這點 - 我不能夠讀取他們的答覆（我看到他們通過發送Wires

0熱度

1回答

春季集成郵件入站通道適配器配置爲POP3訪問和使用輪詢配置後運行一段時間後掛起

<int:channel id="emailInputChannel"/>  <task:executor id="emailPollingExecutor" pool-size="1" /> <int-mail:inbound-channel-adapter id="pop3EmailAdapter"

0熱度

1回答

ImapMailReceiver的不當行爲

如果密碼包含@，ImapMailReceiver無法正確返回主機。例如：用戶名：[email protected] 密碼：ABC @ 123 主機：imap.gmail.com 最終URI字符串 IMAP：//[email protected]：ABC @ 123 @ imap.gmail.com：993/INBOX 然後，ImapMailReceiver識別主機作爲[email protec

0熱度

1回答

使用Spring集成SFTP遞歸讀取文件DSL

我試圖從所有子文件夾遞歸地從遠程服務器上使Spring集成SFTP讀取文件（.txt）。遠程文件夾類似於「/ tmp/remoteFolder」，所有子文件夾都是日期文件夾，如「/ tmp/remoteFolder/20180830」，「/ tmp/remoteFolder/20170902」。這是我到現在爲止 @Bean @InboundChannelAdapter(value = "sft