spring-integration

0열

1답변

Spring에서 지연된 이벤트로 ApplicationEventPublisher를 사용하는 방법이 있습니까?

이벤트 구동 메커니즘을 사용해야합니다. ApplicationEventPublisher을 사용하십시오. 이 이벤트를 수신하는 엔드 포인트에 도달하기 전에 메시지 지연을 설정하려고합니다. 그런 방법이 있습니까? https://docs.spring.io/spring-integration/docs/2.0.0.RC1/reference/html/delayer.html

1열

1답변

는 <INT-HTTP : 아웃 바운드 게이트웨이> 메시지 컨버터를 사용하는 방법을

내 Spring 통합 구성 파일을 갖는 <int-http:outbound-gateway request-channel="loadToFtpChannel" url="http://localhost:8107/ftpService/processFTP" http-method="POST" message-converters="ftpMessgaeCon

0열

1답변

SftpOutboundGateway를 사용하여 스프링 배치에서 원격 파일 나열하기

스프링 배치 분할을 사용하고 있으며 처리를 위해 각 파티션에 파일 목록을 보내고 싶습니다. SftpOutboundGateway를 호출하고 스프링 배치 Partitioner에서 원격 파일 이름 목록을 가져 오는 방법을 알아야합니다.

0열

1답변

Spring 통합을 사용하는 TCP를 사용하여 MessageSource 생성

Spring에서 MessageSource를 생성하는 가장 좋은 방법은 서버에서 데이터를 수신하는 TCP 클라이언트와 통합하는 것입니다. 내 응용 프로그램은 이미 FTP 및 SFTP의 데이터로 wotking하고 있지만 TCP로 버전을 구현해야합니다. 이전 버전의 진입 점은이 같은 InboundChannelAdapter이었다 @Bean @InboundChan

0열

1답변

스프링 통합 DSL 두 채널에 같은 메시지가 있습니다.

두 개의 다른 채널에서 동일한 메시지 (페이로드)를 처리해야한다는 요구 사항이 있습니다. PubliSHSubscribe 채널을 사용하면 두 채널 모두에 메시지 사본을 만들어 문제를 해결할 수 있습니다. 그러나 우리는 각 채널이 하나씩 차례로 실행되고 있다고 생각하고, 하나의 채널에서 페이로드를 변경하면 다른 채널의 페이로드에도 영향을 미칩니다. 난 bean

1열

1답변

스프링 통합 websocket "outputChannel"또는 "outputChannelName"이 필요합니다. 예외 "

저는 Spring 통합 프레임 워크를 처음 사용합니다. 스프링 통합 웹 소켓 샘플 code을 실행하는 동안 'outputChannel'또는 'outputChannelName'이 필요합니다. 예외입니다. 내가 무엇을 놓쳤습니까? 다음 내 코드는, @Configuration @ComponentScan @EnableAutoConfiguration @Rest

0열

1답변

스프링 원격 배치 슬레이브를 조절하는 방법

정의 된 시간대에 최대 1 백만 청크를 처리 할 수 있어야하므로 여러 청크 일괄 처리 작업을 원격 청크 일괄 처리로 변환하는 중입니다. 우리는 일자리를 운영하고 있지만 성과와 관련된 몇 가지 문제가 있습니다. Google의 작업은 항목/청크 당 처리 시간이 비교적 길며 일반적으로 몇 초입니다. 우리는 슬레이브 측에 다음과 같은 구성을 사용하지 : 우리

2열

1답변

bean kafkaListenerContainer를 시작하지 못했습니다 : java.lang.IllegalArgumentException

스프링 통합을 사용하여 파일을 읽는 예제로 this을 사용하고 있지만, kafka 제작자에게 파일을 보내려고하면 작동하지 않습니다. 인터넷에서이 문제를 조사하려했지만 도움을 찾을 수 없었습니다. 파일 : MessageProcessingIntegrationFlow.java : 여기 @Bean public IntegrationFlow writeToFile()

0열

1답변

스프링 통합 - 병렬 오더 처리

애플리케이션에서 나는 TCP 소켓에서 계속되는 메시지 흐름이있다. 메시지에는 다른 유형이 있습니다. 서로 다른 유형의 메시지를 병렬로 처리해야합니다. 그러나 각 특정 유형의 메시지는 들어오는 순서대로 처리되어야합니다. 스프링 통합에서 ExecutorChannel을 사용하고 병렬 처리 필요를 해결합니다. 특정 유형의 메시지마다 채널을 만들었습니다. 하지만 특

0열

1답변

spring integration rabbitmq 준비 상태 메시지

나는 spring과 rabbitmq의 통합 상황이 있습니다. 메시지는 대기열로 보내지지만 준비 상태로 끝나고 승인되지 않은 메시지로 보내지지만 소비자는 메시지를 가져 오지 않습니다. 들으 XML 구성은 다음과 같이이다 : 서버에서 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:x