jms outbound gateway and aggregator

[mfcplus]

Hi, I'm getting failing to receive jms message within timeout exception with the following configs, I just want to see if i get the message back or not, can anyone tell me what i did wrong? I copied the aggregator stuff from Oleg's 2011 spring conference. thanks

<si-jms:outbound-gateway id="mygateway" request-channel="splitchannel" request-destination="outboundQueue"
reply-channel="myReplyChannel" reply-destination-name="QUEUEUNAME"
connection-factory="queueConnectionFactory"/>

<si:aggregator input-channel="myReplyChannel" output-channel="loggingChannel"
release-strategy-expression="size() == 1"
send-partial-result-on-expiry="true" message-store="messageStore"
expire-groups-upon-completion="false"/>

<si:logging-channel-adapter id="loggingChannel" log-full-message="true"/>

<bean id="messageStore" class="org.springframework.integration.store.Simpl eMessageStore"/>

[ray.frid]

Any luck with this?

[mfcplus]

no luck, I have a service activator with a bean ref using the outputchannel of the outbound gateway, the reply is not going to that method at all. any help is appreciated

thanks

[oleg.zhurakousky]

I'd suggest to look at the JMS sample https://github.com/SpringSource/spri...ster/basic/jms first

Looking at your configuration it does not seem to be complete. You have JMS Outbound Gateway which implies that it will send a Message to JMS and receive a reply from JMS. Do you have something in the other side that produces a reply?

[mfcplus]

Hi, the external queue is a mainframe queue that sends response back as a reply, but my service activator is not picking them up in the replyqueue

[oleg.zhurakousky]

I don't see how Queue can send a reply back. Do you mean there is some listener on the mainframe that listens to the 'QUEUEUNAME' and sends a reply back to the replyQueue?

It seems to me that the reply is not coming.

I'd suggest to simplify configuration to first simply validate that reply is coming by configuring a logger to the 'myReplyChannel'

<si-jms:outbound-gateway id="mygateway" request-channel="splitchannel" request-destination="outboundQueue"
reply-channel="myReplyChannel" reply-destination-name="QUEUEUNAME"
connection-factory="queueConnectionFactory"/>

<si:logging-channel-adapter channel="myReplyChannel" level="WARN"/>

Also, could it be that the mainframe is too slow with response? Try setting 'receive-timeout' attribute to some significant value. The default is 1 sec. so set it to 10 (e.g., receive-timeout="10000")