public interface QueueChannelOperations
Modifier and Type | Method and Description |
---|---|
List<Message<?>> |
clear()
Remove all
Messages from this channel. |
int |
getQueueSize() |
int |
getRemainingCapacity() |
List<Message<?>> |
purge(MessageSelector selector)
Remove any
Messages that are not accepted by the provided selector. |
List<Message<?>> clear()
Messages
from this channel.List<Message<?>> purge(MessageSelector selector)
Messages
that are not accepted by the provided selector.selector
- The message selector.int getQueueSize()
Messages
in this channel.int getRemainingCapacity()