Package org.springframework.integration.channel

Class ChannelPurger

java.lang.Object

org.springframework.integration.channel.ChannelPurger

public class ChannelPurger
extends Object

A utility class for purging Messages from one or more QueueChannels. Any message that does not match the provided MessageSelector will be removed from the channel. If no MessageSelector is provided, then all messages will be cleared from the channel.

Note that the purge() method operates on a snapshot of the messages within a channel at the time that the method is invoked. It is therefore possible that new messages will arrive on the channel during the purge operation and thus will not be removed. Likewise, messages to be purged may have been removed from the channel while the operation is taking place. Such messages will not be included in the returned list.

Author:

Mark Fisher, Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
ChannelPurger(QueueChannel... channels)
ChannelPurger(MessageSelector selector, QueueChannel... channels)

Method Summary

Modifier and Type	Method	Description
List<Message<?>>	purge()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ChannelPurger

public ChannelPurger(QueueChannel... channels)

ChannelPurger

public ChannelPurger(@Nullable MessageSelector selector, QueueChannel... channels)

Method Details

purge

public final List<Message<?>> purge()