org.springframework.xd.dirt.plugins.spark.streaming

Class SparkStreamingChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.channel.AbstractSubscribableChannel

org.springframework.integration.channel.DirectChannel

org.springframework.xd.dirt.plugins.spark.streaming.SparkStreamingChannel

All Implemented Interfaces:

java.io.Serializable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.integration.channel.ChannelInterceptorAware, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ConfigurableMetricsAware<org.springframework.integration.support.management.AbstractMessageChannelMetrics>, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.IntegrationStatsManagement, org.springframework.integration.support.management.MessageChannelMetrics, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageChannel, org.springframework.messaging.SubscribableChannel

public class SparkStreamingChannel
extends org.springframework.integration.channel.DirectChannel
implements java.io.Serializable

The DirectChannel that provides support for spark streaming configurations.

Since:

1.1

Author:

Ilayaperumal Gopinathan

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

Field Summary

Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel

interceptors

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
SparkStreamingChannel()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	configureMessageConverter(org.springframework.util.MimeType contentType) Configure message converter for this direct channel.

Methods inherited from class org.springframework.integration.channel.DirectChannel

getDispatcher, onInit, setFailover, setMaxSubscribers

Methods inherited from class org.springframework.integration.channel.AbstractSubscribableChannel

doSend, subscribe, unsubscribe

Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel

addInterceptor, 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, setStatsEnabled

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.messaging.MessageChannel

send, send

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Constructor Detail

SparkStreamingChannel

public SparkStreamingChannel()

Method Detail

configureMessageConverter

protected void configureMessageConverter(org.springframework.util.MimeType contentType)

Configure message converter for this direct channel.

Parameters:

contentType - the content type to use