public class RendezvousChannel extends QueueChannel
QueueChannel
that delegates to a
SynchronousQueue
internally. This accommodates "handoff" scenarios
(i.e. blocking while waiting for another party to send or receive).AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
queueSemaphore
interceptors, meters
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
INDEFINITE_TIMEOUT
Constructor and Description |
---|
RendezvousChannel() |
clear, destroy, doReceive, doSend, getQueueSize, getRemainingCapacity, purge, registerMetricsCaptor
addInterceptor, addInterceptor, getReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong, hasExecutorInterceptors, receive, receive, removeInterceptor, removeInterceptor, setInterceptors
configureMetrics, getComponentType, getErrorRate, getFullChannelName, getIChannelInterceptorList, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMetricsCaptor, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, reset, send, send, setCountsEnabled, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong, receiveCount, receiveErrorCount
isStatsEnabled, setStatsEnabled
getOverrides, isCountsEnabled, isLoggingEnabled, reset, setCountsEnabled, setLoggingEnabled
send, send
getChannelInterceptors
getInterceptors
getBeanName, getComponentName
sendCount, sendErrorCount