public class ChannelPurger
- extends java.lang.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.
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.
- Mark Fisher
|Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ChannelPurger(QueueChannel... channels)
public ChannelPurger(MessageSelector selector,
public final java.util.List<Message<?>> purge()