如何在Spring集成订阅源中使用多个rss订阅源删除重复消息

Question

如何使用共享MetadataStore的FeedEntryMessageSource在Spring集成订阅源中删除具有多个rss订阅源的重复消息。

我跟着这个例子https://github.com/okihouse/spring-integration-rss-multiple-urls，对于多个URL，现在我想从每个源删除重复的消息。我怎么能做到这一点？

Answer 1

我想你应该看看Idempotent Receiver模式。

而且在拆分所有List<SyndFeed>之后，您应该检查您是否还没有处理过该条目。我的意思是splitter之后的下一个终点应该标记为IdempotentReceiverInterceptor。

编辑

@Bean 
@Splitter(inputChannel = "splitterChannel") 
public MessageHandler splitter() { 
    DefaultMessageSplitter defaultMessageSplitter = new DefaultMessageSplitter(); 
    defaultMessageSplitter.setOutputChannelName("serviceChannel"); 
    return defaultMessageSplitter; 

} 

@Bean 
public IdempotentReceiverInterceptor idempotentReceiverInterceptor() { 
    return new IdempotentReceiverInterceptor(new MetadataStoreSelector(...)); 
} 


@ServiceActivator(inputChannel = "serviceChannel") 
@IdempotentReceiver("idempotentReceiverInterceptor") 
public void processFeed(SyndFeed feed) { 
    ... 
}