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