org.springframework.xd.dirt.plugins

Class AbstractStreamPlugin

java.lang.Object

org.springframework.xd.dirt.plugins.AbstractPlugin

org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

org.springframework.xd.dirt.plugins.AbstractStreamPlugin

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, Plugin

Direct Known Subclasses:

SparkStreamingPlugin, StreamPlugin

public abstract class AbstractStreamPlugin
extends AbstractMessageBusBinderPlugin

Abstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related to stream plugins.

Author:

Ilayaperumal Gopinathan, Mark Fisher, Gary Russell

Field Summary

Fields inherited from class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL

Fields inherited from class org.springframework.xd.dirt.plugins.AbstractPlugin

logger, PLUGIN_CONTEXT_CONFIG_ROOT

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
AbstractStreamPlugin(MessageBus messageBus)
AbstractStreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.String	buildTapChannelName(Module module)
protected java.lang.String	getInputChannelName(Module module)
protected java.lang.String	getOutputChannelName(Module module)
boolean	supports(Module module) Check if the module is supported by the plugin.

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

beforeShutdown, bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, removeModule, unbindConsumer, unbindProducers

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractPlugin

getApplicationContext, postProcessModule, preProcessModule, setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStreamPlugin

public AbstractStreamPlugin(MessageBus messageBus)

AbstractStreamPlugin

public AbstractStreamPlugin(MessageBus messageBus,
                    ZooKeeperConnection zkConnection)

Method Detail

getInputChannelName

protected java.lang.String getInputChannelName(Module module)

Specified by:

getInputChannelName in class AbstractMessageBusBinderPlugin

getOutputChannelName

protected java.lang.String getOutputChannelName(Module module)

Specified by:

getOutputChannelName in class AbstractMessageBusBinderPlugin

buildTapChannelName

protected java.lang.String buildTapChannelName(Module module)

Specified by:

buildTapChannelName in class AbstractMessageBusBinderPlugin

supports

public boolean supports(Module module)

Description copied from interface: Plugin

Check if the module is supported by the plugin.

Specified by:

supports in interface Plugin

Specified by:

supports in class AbstractPlugin

Parameters:

module - the module to check for support