org.springframework.xd.greenplum.gpfdist

Class GPFDistMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.xd.greenplum.gpfdist.AbstractGPFDistMessageHandler

org.springframework.xd.greenplum.gpfdist.GPFDistMessageHandler

All Implemented Interfaces:

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.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.core.Ordered, org.springframework.integration.context.Orderable, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ConfigurableMetricsAware<org.springframework.integration.support.management.AbstractMessageHandlerMetrics>, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.IntegrationStatsManagement, org.springframework.integration.support.management.MessageHandlerMetrics, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageHandler

public class GPFDistMessageHandler
extends AbstractGPFDistMessageHandler

Field Summary

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
GPFDistMessageHandler(int port, int flushCount, int flushTime, int batchTimeout, int batchCount, int batchPeriod, java.lang.String delimiter)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart() Subclasses may override this method with the start behaviour.
protected void	doStop() Subclasses may override this method with the stop behaviour.
protected void	doWrite(org.springframework.messaging.Message<?> message) Subclasses need to implement this method to handle Message in its writer.
protected void	onInit()
void	setGreenplumLoad(GreenplumLoad greenplumLoad)
void	setRateInterval(int rateInterval)
void	setSqlTaskScheduler(org.springframework.scheduling.TaskScheduler sqlTaskScheduler)

Methods inherited from class org.springframework.xd.greenplum.gpfdist.AbstractGPFDistMessageHandler

getPhase, handleMessageInternal, isAutoStartup, isRunning, setAutoStartup, setPhase, start, stop, stop

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, 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, setConversionService, 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.integration.support.context.NamedComponent

getComponentName

Constructor Detail

GPFDistMessageHandler

public GPFDistMessageHandler(int port,
                     int flushCount,
                     int flushTime,
                     int batchTimeout,
                     int batchCount,
                     int batchPeriod,
                     java.lang.String delimiter)

Method Detail

doWrite

protected void doWrite(org.springframework.messaging.Message<?> message)
                throws java.lang.Exception

Description copied from class: AbstractGPFDistMessageHandler

Subclasses need to implement this method to handle Message in its writer.

Specified by:

doWrite in class AbstractGPFDistMessageHandler

Parameters:

message - the message to write

Throws:

java.lang.Exception

onInit

protected void onInit()
               throws java.lang.Exception

Overrides:

onInit in class org.springframework.integration.handler.AbstractMessageHandler

Throws:

java.lang.Exception

doStart

protected void doStart()

Description copied from class: AbstractGPFDistMessageHandler

Subclasses may override this method with the start behaviour. This method will be invoked while holding the AbstractGPFDistMessageHandler.lifecycleLock.

Overrides:

doStart in class AbstractGPFDistMessageHandler

doStop

protected void doStop()

Description copied from class: AbstractGPFDistMessageHandler

Subclasses may override this method with the stop behaviour. This method will be invoked while holding the AbstractGPFDistMessageHandler.lifecycleLock.

Overrides:

doStop in class AbstractGPFDistMessageHandler

setSqlTaskScheduler

public void setSqlTaskScheduler(org.springframework.scheduling.TaskScheduler sqlTaskScheduler)

setGreenplumLoad

public void setGreenplumLoad(GreenplumLoad greenplumLoad)

setRateInterval

public void setRateInterval(int rateInterval)