public class SparkStreamingChannel
extends org.springframework.integration.channel.DirectChannel
implements java.io.Serializable
DirectChannel that provides support for
spark streaming configurations.| Constructor and Description |
|---|
SparkStreamingChannel() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
configureMessageConverter(org.springframework.util.MimeType contentType)
Configure message converter for this direct channel.
|
getDispatcher, onInit, setFailover, setMaxSubscribersdoSend, subscribe, unsubscribeaddInterceptor, addInterceptor, getChannelInterceptors, getComponentType, getFullChannelName, getInterceptors, removeInterceptor, removeInterceptor, send, send, setConversionService, setDatatypes, setInterceptors, setMessageConverter, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toString