public class SparkStreamingChannel
extends org.springframework.integration.channel.DirectChannel
implements java.io.SerializableDirectChannel。| コンストラクターと説明 |
|---|
SparkStreamingChannel() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | configureMessageConverter(org.springframework.util.MimeType contentType) この直接チャネルのメッセージコンバーターを構成します。 |
getDispatcher, onInit, setFailover, setMaxSubscribersdoSend, subscribe, unsubscribeaddInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, removeInterceptor, removeInterceptor, reset, send, send, setConversionService, setCountsEnabled, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toString