spring-xd

0熱度

2回答

將Spring集成中的JMX bean MessageHistory註冊到Spring XD模塊時出現異常

如果我在開發Spring XD模塊時嘗試使用Spring集成中的Message History bean「int：message-history」，嘗試導出時失敗JMX bean。我見過的，所使用的命名策略是org.springframework.xd.dirt.module.jmx.ModuleObjectNamingStrategy 我已經打開該https://jira.spring.io/

0熱度

1回答

將自定義類型轉換器添加到Spring XD

不幸的是，似乎Spring XD沒有附帶XML類型轉換器（application/xml）。我實現了2 AbstractFromMessageConverter s用於將POJO轉換爲XML，反之亦然。根據documentation它說看看streams.xml我認爲他們真的指的是this XML。我提供了一個名爲customMessageConverters的列表和我自己的Configura

0熱度

1回答

如何在Spring XD中實現自定義模塊中的日誌記錄？

調試部署到Spring XD運行時（版本1.3.1-RELEASE）的自定義模塊並不那麼容易。我知道log接收器，但它是不同的，我想實現。我想將自己的日誌消息添加到XD日誌（理想情況下是STDOUT以及它自己的日誌）。這些日誌消息使用slf4j API在我的自定義模塊（本例中爲處理器）中生成。我說： org.slf4j.Logger#info調用到處理器類 logback-classic依賴

1熱度

1回答

文件在處理之前被刪除

我有一個spring的xd模塊，用於從s3中拉取文件並逐行分割並在處理後將其刪除（ExpressionAdvice）。我的文件中有大約100萬條消息（行） s3。文件被下載到xd容器框中，並且我檢查了md5sum和它的相同並且具有相同的行。我看到只有260k個奇怪的消息來到輸出通道，這是處理器。我丟失了大約740條消息。有時它隨機一次，我看到所有消息，如100萬在我的輸出通道，有時只有250k。我

2熱度

1回答

如何在Spring Integration DSL的SpEL表達式中使用Spring XD Module選項？

我正在實現一個自定義Spring XD模塊（處理器）。我已經將模塊選項添加到它，它們可以通過@Value("${varName}")語法在ModuleConfiguration中輕鬆引用。 return IntegrationFlows .from(input) .enrichHeaders(h -> h .headerExpression("var

5熱度

1回答

如何從卡桑德拉表中流出數據？

我想從實時更新的cassandra表中流式傳輸數據。是的，這是一個數據庫，但有沒有辦法做到這一點？如果是這樣，保留偏移量或可以使用哪些CQL查詢？

1熱度

1回答

當調用高併發0123調用http調用時丟失消息

嗨我有像下面的流定義。在哪裏我從s3拉文件分割線並呼叫http客戶端，並把放到指定channel.My運輸是兔子和prefetch是10和併發的http是100並且運行在3個容器和1個管理員上。 stream aws-s3|custom processor| custom-http-client --url1=https://test1.com --url2=https://test1.com -

0熱度

1回答

如何在Spring-XD作業中使用shellCommandProceccesor

在SPring XD中，有一個通用模塊可以使用Shell命令處理器運行shell命令。 Spring Common Processor Module Github 我想利用SHELL命令在開始的主要工作（這是MR /蜂巢/豬節目的順序）之前我的春節-XD組成的工作。有沒有辦法在XD-job中實現這一點，而不是通過創建流。我找不到任何運行shell/bash腳本的tasklet來利用我的xd-jo

1熱度

1回答

注入春天的整合/ XD HTTP的出站

您好我有流定義，就像我below.Where通過線拉從S3分割線文件，並調用HTTP客戶端，並把名爲channel.My運輸兔和 2個不同的模板休息 stream aws-s3|custom processor| custom-http-client --url1=https://test1.com --url2=https://test2.com --filterAttribute=messag

0熱度

1回答

如何從模塊本身獲取Spring XD模塊元數據

我創建了一個需要訪問其ModuleMedatada的Spring XD模塊。我可以通過ZooKeeperModuleMetadataRepository獲取元數據，但我還沒有找到如何唯一標識我的運行模塊。給出的樣本模塊： @MessageEndpoint public class DummyAugmenter { @Transformer(inputChannel = "inpu