spring-integration

1열

1답변

int : outbound-websocket-adapter가 MESSAGE 프레임을 보내고 있습니다. 나는 SEND 프레임을 기대했다.

Bakground : jms 메시지를 통해 배치 작업을 트리거하고 websocket을 통해 클라이언트에게 피드백을 보내고 싶다. 문제 : 서버가 클라이언트로부터 MESSAGE 프레임을 받지만 SEND 프레임이 필요합니다. 따라서 주제 (/ topic/export-status) 가입자는 jobExection 상태를받지 못합니다. 질문 : 어떻게 해결할 수 있

1열

1답변

스프링 통합 - 스레딩 된 아웃 바운드 채널

미리 감사드립니다! 나는 목표가 많은 클라이언트를 서버에 연결하고 클라이언트와 서버 사이의 비동기 메시지를 원활하게하는 간단한 TCP 통합 작업을하고 있습니다. 어떤 코드를 예제와 함께 사용하면 모든 것이 예상대로 작동합니다 : 하나의 연결이 끊어지면 (모든 연결이 끊어지지 않고 모든 패킷이 삭제됩니다) 다른 모든 연결은 메시지가 수신 될 때까지 메시지 수

0열

1답변

스프링 통합을 사용하여 TCP 연결에서 연결 유지 연결을 구현하는 방법은 무엇입니까?

나는 스프링 통합 TCP를 사용하여 빌드 된 TCP 클라이언트를 가지고 있으며 서버는 활성 상태 메시지 (ping/pong 스타일)를 지원합니다. 연결은 CachingClientConnectionFactory을 사용하여 구성되었으며이 서버 기능을 활용하고 싶습니다. private static final int SERIALIZER_HEADER_SIZE = 2

0열

1답변

오류 : 'ConnectionFactory에'

암은 봄이 org.springframework.beans.factory 예외 아래 integration.getting의 도움으로 웹 로직 큐를 들으려고 빈에 대한 참조를 확인할 수 없습니다. BeanCreationException : 이름이 'inboundJms.container'인 Bean을 생성하는 중 오류가 발생했습니다 : 'connectionFact

0열

1답변

봄 통합 - 메시징 게이트웨이 오버로드 된 메서드

에게 노출하는 I가 메시징 게이트웨이에 의해 SomeInterface.java`를 노출하는 인터페이스 interface SomeInterface { Outcome doSomething(String p1); Outcome doSomething(String p1, String p2); } 나머지-beans.xml 환경 <int:gatew

0열

1답변

스프링 통합 인바운드 채널 어댑터를 사용할 때 메시지를 다시 다운로드

메시지를 읽으면 스프링 메일 인바운드 채널 어댑터를 사용하여 메일을 읽습니다. 해당 채널의 서비스 활성화 프로그램에서 일부 db 작업을 수행하고 있습니다. 내 요구 사항은 DB 작업이 실패하면 어댑터가 동일한 메시지를 다시 읽어야한다는 것입니다. 메일 구성 : @Bean public DirectChannel inputChannel() { retu

1열

1답변

봄 - 통합 : QueueChannel

짧은 요약 : 나는 큐에 메시지를 보내고 여러 스레드가이 메시지를 처리 할 수 있도록 할 . 응용 프로그램은 메시지를 게이트웨이에 비동기 적으로 보내야하지만 큐가 가득 차면 차단되어야합니다. 또한 Queue multi-threaded 로의 전달을 원했습니다. 내 문제는 내 대기열이 절대로 차단하지 않고 실제 크기가 더 많은 메시지를 전달한다는 것입니

0열

1답변

파일 아웃 바운드 어댑터에서 변압기로 헤더 특성을 전달하는 방법

파일 아웃 바운드 어댑터를 사용하여 파일을 읽고 스프링 통합 DSL을 사용하여 일련의 트랜스포머를 통과시키고 파일 이름에 이러한 트랜스포머가 액세스 할 수 없다는 사실을 알았습니다. 어떻게 아래에서 초기 파일 이름을 전달할 수 있습니다 IntegrationFlows.from(Files .inboundAdapter(new File(this.pro

0열

1답변

TCP 메시지 - 내구성 있고 빠른 솔루션 정보?

우리는 하드웨어와의 TCP 소켓 통신을 위해 Spring 통합을 사용한다. 클라이언트는 메시지를 고유하게 식별하기 위해 시퀀스 번호를 보냅니다. 필자의 요구 사항은 이러한 시퀀스 번호를 소켓 메시지의 일부로 저장하고 비 반복적 인 시퀀스 번호에 대해 유효성을 검사하는 것입니다. IdempotentReceiver를 통해 갔다. 내가 원한 것처럼 들린다. 그러

0열

1답변

스프링 통합 : 모든 보내는 오류 메시지를 조정하는 방법

예외로 던져 지거나 비동기 오류로 처리되었는지에 관계없이 정보가 누출되지 않도록 통합 플로우의 호출자에게 돌아가는 모든 오류 메시지를 조정해야합니다. . 모든 메시지 처리기에서 사용자 정의 오류 채널을 정의하는 것을 피하고 싶습니다. @Bean IntegrationFlow errorFlow() { return IntegrationFlows.fro