Announcement Announcement Module
Collapse
No announcement yet.
Aggregator not timing out Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • 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, 08:02 AM.

  • #2
    Please check out my post in http://forum.springsource.org/showth...egator-Example

    Comment

    Working...
    X