-
Jun 1st, 2011, 02:59 AM
#1
Aggregator not timing out
Hi,
I am facing some issues with my aggregator.
I have specified a timeout for my aggregator.
I want the aggregator to discard the message if all messages are not recieved within a specific time.
I have specified a discard channel for it too.
But my aggregator is not timing out.
It works fine when there is a duplicate message.It redirects to the discard channel.
My configuration is:
<int-http:inbound-channel-adapter id="smsInboundAdapter"
channel="smsChannel" name="/smsInboundAdapter.htm" supported-methods="GET" />
<int:channel id="smsChannel" />
<int:transformer id="smsToMessageConverter"
input-channel="smsChannel" output-channel="aggregationChannel" >
<bean class="sms.communication.SMSToMessageConverter" />
</int:transformer>
<int:channel id="aggregationChannel" />
<int:channel id="errorChannel" />
<int:aggregator method="add" input-channel="aggregationChannel"
output-channel="completeMessageChannel"
discard-channel="errorChannel" send-timeout="30000" >
<bean class="sms.communication.MessageAggragator" />
</int:aggregator>
<int:outbound-channel-adapter ref="errorUnWrapper"
channel="errorChannel" />
<int:channel id="completeMessageChannel" />
<int:outbound-channel-adapter ref="messageProcessor"
channel="completeMessageChannel" />
<bean id="messageProcessor" class="sms.communication.MessageProcessor" />
<bean id="errorUnWrapper" class="sms.communication.ErrorUnWrapper" />
I am considering the send timeout value in milliseconds..
Please help.
Last edited by annuk; Jun 1st, 2011 at 07:02 AM.
Tags for this Thread
Posting Permissions
- You may not post new threads
- You may not post replies
- You may not post attachments
- You may not edit your posts
-
Forum Rules