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.ChannelInterceptorListqueueSemaphoreloggerINDEFINITE_TIMEOUT| Constructor and Description |
|---|
RendezvousChannel() |
clear, doReceive, doSend, getQueueSize, getRemainingCapacity, purgegetReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLong, receive, receiveaddInterceptor, addInterceptor, configureMetrics, enableCounts, enableStats, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, removeInterceptor, removeInterceptor, reset, send, send, setConversionService, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetReceiveCount, getReceiveCountLong, getReceiveErrorCount, getReceiveErrorCountLonggetErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSendenableStats, isStatsEnabledenableCounts, isCountsEnabled, isLoggingEnabled, reset, setLoggingEnabledsend, sendgetComponentName