Spring JMS 통합에서 간격 기반 cron 구성

Queue1에 메시지가 도착한 직후가 아니라 지정된 간격으로 Queue1에서 Queue2로 메시지를 전달해야합니다. 아래는 내 설정입니다. 폴러> 구성 :Spring JMS 통합에서 간격 기반 cron 구성

<int-jms:inbound-channel-adapter id="inboundChannelAdapterId" connection-factory="connFactory" destination="jmsQueue1" channel="queueChannel" > 
    <int:poller send-timeout="2000" > 
     <!-- 
     <int:interval-trigger initial-delay="60000" interval="60000" 
     fixed-rate="true"/> 
     --> 
     <int:cron-trigger expression="0 0/1 * * * ?" /> 
    </int:poller> 
</int-jms:inbound-channel-adapter> 

<int-jms:outbound-channel-adapter channel="queueChannel" connection-factory="connFactory" destination="jmsQueue2" > 
</int-jms:outbound-channel-adapter> 

<int:channel id="queueChannel" />

상기 XML 구성 < INT를 무시하고 queue1을 행 Queue2 즉시 메시지를 전송한다. 나는 간격 기반 및 cron 기반 솔루션을 모두 시도해 보았고 비슷한 (Queue1에서 Queue2로 즉시 메시지 전달)하는 것처럼 보입니다. 여기에 "폴러"구성에 문제가 있습니까? 어떤 도움을 많이 주시면 감사하겠습니다.

출처

2012-02-02 CoderTR

~~어댑터에서 수신 제한 시간이 필요합니다. 그렇지 않으면 receive()를 차단하고 즉시 메시지를받습니다.~~

편집 : 아래의 주석 참조 - 대기열을 폴링하는 스레드는 2.0.4 이후 더 이상 기본적으로 차단되지 않습니다.

폴러에 2.0+ 구문을 사용하는 것도 좋습니다. 현재 구문은

<jms:inbound-channel-adapter id="in" channel="jmsinToStdoutChannel" destination="requestQueue"> 
    <poller fixed-delay="30000"/> 
</jms:inbound-channel-adapter>

그냥 ... 명확히하기 위해 수신 타임 아웃이 어댑터에 설정되어있는 경우, 폴러 스레드는 그 긴 또는 메시지까지 차단됩니다 ... 2.0에서 사용되지 않는 2.1에서 허용되지 않았다 도착한다. 폴러가 스케줄을 따르지 않는 것처럼 보일 수 있습니다. 기본값 (2.0.4부터)은 블로킹하지 않는 것이고 이는 폴러 스케줄에서만 메시지가 수신됨을 의미합니다.

출처

2012-03-01 20:57:46

답장을 보내 주셔서 감사합니다. 나는 당신의 제안을 시도했으나 문제를 해결하지 못했습니다. 내가 다시 의사를 통해 갔을 때 @ [link] (http://static.springsource.org/spring-integration/reference/htmlsingle/),이 기능은 큐 기반 어댑터가 수신으로 지원되지 않는다는 것을 알려줍니다 차단되지 않습니다 기다려 ?? ** 한편, Spring Integration 자체의 대기열 기반 채널을 사용할 때, 타임 아웃 값에 참여할 기회가 있습니다. 다음 예는 Polling Consumer가 거의 즉각적으로 메시지를 수신하는 방법을 보여줍니다. ** 이전에 이것을 시도한 적이 있습니까? 다시 한 번 감사드립니다! – CoderTR

어떤 스프링 통합 버전을 사용하고 있습니까? 기본적으로 차단 호출을하지 않으려면 2.0.4에서 동작이 변경되었습니다. https://github.com/garyrussell/spring-integration/commit/b59bdc0d70087b015589a70ed3cb32ef44cf6dd6 –

현재 2.0.x 버전은 2.0.5입니다. 2.1.0도 사용할 수 있습니다. –

Spring JMS 통합에서 간격 기반 cron 구성

답변

관련 문제