spring-dsl

0熱度

2回答

我想發送文件到SFTP服務器。我已經創造了它 @Bean public IntegrationFlow sftpOutboundFlow() { return IntegrationFlows .from("toSftpChannel") .handle(Sftp.outboundAdapter(this.smileCachedSftpSessionFact

2熱度

1回答

爲什麼集成流程無法訂閱從渠道？

對我來說，這似乎只是最簡單的彈簧集成示例。我試圖從si4demo中學習。但是，當我運行它，我得到這個異常：在線程異常「主」 org.springframework.messaging.MessageDeliveryException：調度員已通道「application.inbox」沒有用戶;嵌套的例外是 org.springframework.integration.MessageDispa

2熱度

2回答

Spring集成DSL JDBC入站通道適配器

我使用spring集成從數據庫中讀取數據。現在我使用輪詢適配器 @Bean public MessageSource<Object> jdbcMessageSource() { JdbcPollingChannelAdapter a = new JdbcPollingChannelAdapter(dataSource(), "SELECT id, clientName FROM cl

2熱度

1回答

使用Spring集成DSL郵件時發生ConcurrentModificationException

我正嘗試使用Spring Integration Java DSL來接收電子郵件（gmail）。我也在使用Redis。當我收到郵件時，我收到ConcurrentModificationException。在搜索時，我也發現人們在卡夫卡也遇到同樣的錯誤。以下是我的代碼和例外。感謝您的幫助提前。 Properties javaMailProperties = new Properties();

2熱度

1回答

Spring集成在分割迭代器時抑制異常

以下面的方案爲例：我在Iterator上分割了一條消息。如果在遍歷一個元素時在.handle()內引發異常，則跳過所有其餘元素並獲取下一條消息。我需要抑制任何可能的異常，以便處理迭代器中的所有元素。因爲我使用Iterator而不是List，例如，我無法使用.aggregate()解決此問題。請問我該如何設法達到理想的行爲......？春天引導入門整合1.3.0 Spring集成4.2.1

4熱度

1回答

駱駝+ marklogic沒有使用Marklogic內容泵

我試圖從文件系統中選擇一個json文件，並試圖將文件插入到marklogic數據庫。 <route id="file_upload">  <from uri="file:/E:/camel/input"/> <to uri="http://localhost:8005/

2熱度

1回答

是否有使用Java DSL的Spring集成記錄消息的組件？

我正在使用Spring Integration來開發我的集成場景。當我有寫一些日誌提供一些信息，我寫的是這樣的： @Bean IntegrationFlow blacklist(BlacklistService service) { return m -> m .wireTap(f -> f.handle(t -> log.info("Adding email sourc

1熱度

1回答

具有基本身份驗證的Http出站通道適配器

我想使用Spring Boot和Integration DSL將消息作爲HTTP Post發送到休息服務。有沒有人有一個如何使用（基本）身份驗證做到這一點的例子？其他一切似乎都工作正常。該日誌顯示「org.springframework.web.client.HttpClientErrorException：401 Unauthorized」。

2熱度

1回答

Spring集成DSL KafkaProducerContext配置

我試圖適應下面的例子： https://github.com/joshlong/spring-and-kafka 與下列庫的最新穩定版本： org.apache.kafka > kafka_2.10 > 0.8.2.2 org.springframework.integration > spring-integration-kafka > 1.2.1.RELEASE org.springfra

4熱度

1回答

管道來源爲DSL

我開始對管道工作詹金斯（原工作流程）我使用的IntelliJ一個IDE 是否有文件對GDSL源或一些方法，我可以知道groovy在管道中是可以接受的，哪些不是？另外有沒有一種方法可以在必須檢查我的Jenkinsfile之前運行GDSL？