public class PriorityChannel extends QueueChannel
Comparator.
The default comparator is based upon the message header's 'priority'.AbstractMessageChannel.ChannelInterceptorListlogger| Constructor and Description |
|---|
PriorityChannel()
Create a channel with an unbounded queue.
|
PriorityChannel(java.util.Comparator<org.springframework.messaging.Message<?>> comparator)
Create a channel with an unbounded queue.
|
PriorityChannel(int capacity)
Create a channel with the specified queue capacity.
|
PriorityChannel(int capacity,
java.util.Comparator<org.springframework.messaging.Message<?>> comparator)
Create a channel with the specified queue capacity.
|
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.messaging.Message<?> |
doReceive(long timeout)
Subclasses must implement this method.
|
protected boolean |
doSend(org.springframework.messaging.Message<?> message,
long timeout)
Subclasses must implement this method.
|
clear, getQueueSize, getRemainingCapacity, purgereceive, receiveaddInterceptor, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic PriorityChannel(int capacity,
java.util.Comparator<org.springframework.messaging.Message<?>> comparator)
Comparator. If the comparator
is null, the priority will be based upon the value of
IntegrationMessageHeaderAccessor.getPriority().public PriorityChannel(int capacity)
IntegrationMessageHeaderAccessor.getPriority().public PriorityChannel(java.util.Comparator<org.springframework.messaging.Message<?>> comparator)
Comparator. If the comparator
is null, the priority will be based upon the value of
IntegrationMessageHeaderAccessor.getPriority().public PriorityChannel()
IntegrationMessageHeaderAccessor.getPriority().protected boolean doSend(org.springframework.messaging.Message<?> message,
long timeout)
AbstractMessageChanneldoSend in class QueueChannelprotected org.springframework.messaging.Message<?> doReceive(long timeout)
AbstractPollableChanneldoReceive in class QueueChannel