Announcement Announcement Module
Collapse
No announcement yet.
Can capacity in poller cause lost of messages? Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Can capacity in poller cause lost of messages?

    Hi All,

    I have a configuration such displayed at most bottom. If that poller polls "10" items per 100 milliseconds from prioritizedPublishingRequests channel and if server goes down at that time; those messages will be lost. (Because they are taken from prioritizedPublishingRequests queue to poller's internal queue). Am I correct with this assumption or is there acknowledgement system like in jms?

    I also wonder if there is a way to use priority-queue backed by messageStore as commented in the channel configuration.



    Code:
        <int:channel id="prioritizedPublishingRequests">
            <!-- Spring 2.1 will have message-store for priority-queue INT-1870-->
            <!--<int:priority-queue capacity="100" comparator="publishingRequestComparator" />-->
            <int:queue capacity="100" message-store="messageStore" />
        </int:channel>
    
    
        <int:chain input-channel="prioritizedPublishingRequests" output-channel="splittedPublishingRequests"
                   id="splitterChain">
            <int:poller fixed-rate="100" max-messages-per-poll="10"/>
            <int:header-enricher>
                <int:header name="EVENT_LOGGING_STATUS" value="IN_SPLIT" overwrite="true"/>
            </int:header-enricher>
            <int:splitter>
                   <bean class="com.sony.content.BulkMessageSplitter"/>
            </int:splitter>
        </int:chain>
    Cheers,
    Kaan
Working...
X