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