public interface QueueChannelOperations
| Modifier and Type | Method and Description |
|---|---|
java.util.List<org.springframework.messaging.Message<?>> |
clear()
Remove all
Messages from this channel. |
int |
getQueueSize() |
int |
getRemainingCapacity() |
java.util.List<org.springframework.messaging.Message<?>> |
purge(MessageSelector selector)
Remove any
Messages that are not accepted by the provided selector. |
java.util.List<org.springframework.messaging.Message<?>> clear()
Messages from this channel.java.util.List<org.springframework.messaging.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()