public class MessageSelectingQueueChannel
extends org.springframework.integration.channel.QueueChannel
interceptors
Constructor and Description |
---|
MessageSelectingQueueChannel()
Default constructor.
|
MessageSelectingQueueChannel(BlockingQueue<org.springframework.messaging.Message<?>> queue)
Create a channel with the specified queue.
|
MessageSelectingQueueChannel(int capacity)
Create a channel with the specified queue capacity.
|
Modifier and Type | Method and Description |
---|---|
long |
getPollingInterval()
Gets the pollingInterval.
|
org.springframework.messaging.Message<?> |
receive(org.springframework.integration.core.MessageSelector selector)
Supports selective consumption of messages on the channel.
|
org.springframework.messaging.Message<?> |
receive(org.springframework.integration.core.MessageSelector selector,
long timeout)
Consume messages on the channel via message selector.
|
void |
setPollingInterval(long pollingInterval)
Sets the pollingInterval.
|
clear, doReceive, doSend, getQueueSize, getRemainingCapacity, purge
addInterceptor, addInterceptor, getReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong, hasExecutorInterceptors, receive, receive, removeInterceptor, removeInterceptor, setInterceptors
configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, reset, send, send, setCountsEnabled, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong
getErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend
isStatsEnabled, setStatsEnabled
isCountsEnabled, isLoggingEnabled, reset, setCountsEnabled, setLoggingEnabled
public MessageSelectingQueueChannel(BlockingQueue<org.springframework.messaging.Message<?>> queue)
public MessageSelectingQueueChannel(int capacity)
public MessageSelectingQueueChannel()
public org.springframework.messaging.Message<?> receive(org.springframework.integration.core.MessageSelector selector)
selector
- public org.springframework.messaging.Message<?> receive(org.springframework.integration.core.MessageSelector selector, long timeout)
selector
- timeout
- public long getPollingInterval()
public void setPollingInterval(long pollingInterval)
pollingInterval
- the pollingInterval to setCopyright © 2008–2017 ConSol Software GmbH. All rights reserved.