spring-integration

0열

1답변

나는 단계에 대해 다음 1.) Read messages from a queue 2.) Transform messages 3.) Send transformed messages to an Api 관련 구성을하는 스프링 통합 프로젝트가 1 <bean id="cachingConnectionFactory" class="org.springframework.jm

-1열

1답변

http-inbound-gateway의 오류 채널이 메시지 변환기에서 메시징 예외가 발생하지 않음

<int-http:inbound-gateway id="inboundGateway" path="inboundEndpoint" supported-methods="PUT" request-payload-type="customJsonType" message-converters="jacksonJSONConverte

0열

1답변

DSL을 사용하여 스프링 통합 풍부한 페이로드

저는 RSS 통합을 사용하기 위해 스프링 통합을 사용하고 있습니다. 피드 항목을 얻은 후에는 페이로드의 필드를 사용하여 데이터를 향상시키고 모든 데이터를 DB에 쓰기 전에 Java 클래스를 호출하여 추가 데이터를 가져와 페이로드와 함께 저장해야합니다. 이 작업을 수행하는 가장 좋은 방법은 페이로드 풍부함 또는 서비스 활성기이며 DSL을 사용하여이를 지정하는

0열

1답변

spring-integration-kafka 1.3.1.RELEASE : org.apache.kafka.common.serialization을 사용하는 모든 해결 방법은 무엇입니까?

스프링 XD를 사용하여이 문제를 해결했습니다. 카프카 (0.9 버전)에서받은 메시지를 역 직렬화 할 수있는 해결 방법이 있습니까? 나는 카프카 소스를 asuming (내 스트림을 실행하면 나는 봄 - 통합 - 카프카 1.3.1을 유지하기 위해 의존성을 수정하려고이 <dependency> <groupId>org.springframework.int

3열

1답변

TCP 요청에 대한 응답을 보내는 방법 (스프링 통합)?

Can not send response for UDP message 과 비슷하지만 TCP가 필요합니다. 따라서 클라이언트는 메시지를 보내고 TCP 서버는 OK와 같은 응답을 다시 보낼 수 있습니다. TCP socket-expression = "@ inbound.socket"및 destination-expression = "headers [ 'ip_packe

0열

1답변

스프링 통합 - 파이프 라인 처리 - 디자인

여러 엔드 포인트를 사용하여 메시지를 처리해야하는 메시지 처리 파이프 라인을 설계하려고합니다. 각 단계에서 엔드 포인트는 페이로드 (변환 될 수 있음) 또는 오류 메시지를 리턴합니다. 여기에 내가 내 마음에 무엇을의 일반적인 예는 다음과 같습니다 그래서에 <int:payload-type-router input-channel="preprocessing-out

1열

1답변

핸들러 내에서 스프링 통합 추출 페이로드

DSL을 사용하여 스프링 통합을 처음 사용하고 URI를 동적으로 구성하기 위해 HTTP 처리기 내에서 페이로드를 추출하는 데 어려움이 있습니다. 아래의 통합 흐름은 AccountList Gateway에 의해 트리거되고 "accountListFlow.input"채널의 호출시 메시지에 고객 ID 값을 추가합니다. 페이로드에는 '123766123' 이 포함되며

2열

1답변

Spring Integration에서 새 파일에 라인을 미리 채우는 것

안녕하세요, 저는 Spring Integration에서 SFTP의 파일을 읽고 로컬 파일에 쓰는 통합 플로우를 설계했습니다. 내가 FileExistsMode을 APPEND-MODE로 설정했지만 원격 파일의 내용을 쓰기 전에 파일에 문자열을 미리 추가 할 수 있는지 궁금합니다. 예, 원격 파일은 다음과 같은 내용이 포함 bla bla bla bla bla

2열

1답변

스프링 부트에서 자바에서 TCPConnectionFactory 또는 SSLServerSocketFactory를 설정하는 방법

저는 스프링 부트를 처음 사용하지만 스프링 부트를 사용하여 작은 웹 서비스를 구현하도록 내 작업에서 요청되었습니다. 웹 서비스는 (외부 시스템은 HTTP가 아닌 사용자 정의 프로토콜을 사용하여 웹 서비스에 연결합니다)의 SSL TCP 연결을 허용해야합니다. 또한 백그라운드 작업 (또는 여러 백그라운드 작업)에서 이러한 연결을 처리하고 싶습니다. 공식 문서

1열

1답변

스프링 통합 - 특정 시간에 메시지를 구독 할 수 있습니다.

저는 Spring Integration 및 EIP의 초보자입니다. 나는 스스로를 풀려고했지만 내 마음에는 적절한 해결책이되지 않을 것입니다. 다음은 필요한 흐름의 예입니다. 클라이언트는 Json 데이터를 SI로 보냅니다. HTTP 인바운드 게이트웨이에서 Json 데이터를 페이로드로 가져 왔습니다. 이 Json 데이터는 두 개의 개별 HTTP 아웃 바운드로