org.springframework.xd.dirt.plugins.stream

Class StreamPlugin

java.lang.Object

org.springframework.xd.dirt.plugins.AbstractPlugin

org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

org.springframework.xd.dirt.plugins.AbstractStreamPlugin

org.springframework.xd.dirt.plugins.stream.StreamPlugin

All Implemented Interfaces:

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

public class StreamPlugin
extends AbstractStreamPlugin

Author:

Mark Fisher, Gary Russell, David Turanski, Jennifer Hickey, Glenn Renfro, Ilayaperumal Gopinathan

Field Summary

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

JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL, TAP_CHANNEL_PREFIX, TOPIC_CHANNEL_PREFIX

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
StreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)

Method Summary

Methods

Modifier and Type	Method and Description
void	beforeShutdown(Module module) Perform any cleanup necessary prior to module shutdown
int	getOrder()
void	postProcessModule(Module module) Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.
void	preProcessModule(Module module) Apply changes to the module before it is initialized i.e. before its context is refreshed.

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

buildTapChannelName, getInputChannelName, getOutputChannelName, supports

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

bindConsumerAndProducers, extractConsumerProducerProperties, unbindConsumerAndProducers

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

getApplicationContext, removeModule, setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamPlugin

@Autowired
public StreamPlugin(MessageBus messageBus,
                      ZooKeeperConnection zkConnection)

Method Detail

preProcessModule

public void preProcessModule(Module module)

Description copied from interface: Plugin

Apply changes to the module before it is initialized i.e. before its context is refreshed.

Specified by:

preProcessModule in interface Plugin

Overrides:

preProcessModule in class AbstractPlugin

postProcessModule

public void postProcessModule(Module module)

Description copied from interface: Plugin

Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.

Specified by:

postProcessModule in interface Plugin

Overrides:

postProcessModule in class AbstractPlugin

beforeShutdown

public void beforeShutdown(Module module)

Description copied from interface: Plugin

Perform any cleanup necessary prior to module shutdown

Specified by:

beforeShutdown in interface Plugin

Overrides:

beforeShutdown in class AbstractPlugin

getOrder

public int getOrder()

Specified by:

getOrder in interface org.springframework.core.Ordered

Overrides:

getOrder in class AbstractMessageBusBinderPlugin