public class ChannelPurger extends Object
Messagesfrom one or more
QueueChannels. Any message that does not match the provided
MessageSelectorwill be removed from the channel. If no
MessageSelectoris 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.
- Mark Fisher, Gary Russell, Artem Bilan