public class GPFDistMessageHandler extends AbstractGPFDistMessageHandler
| Constructor and Description |
|---|
GPFDistMessageHandler(int port,
int flushCount,
int flushTime,
int batchTimeout,
int batchCount,
int batchPeriod,
java.lang.String delimiter) |
| 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) |
getPhase, handleMessageInternal, isAutoStartup, isRunning, setAutoStartup, setPhase, start, stop, stopgetComponentType, getOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic GPFDistMessageHandler(int port,
int flushCount,
int flushTime,
int batchTimeout,
int batchCount,
int batchPeriod,
java.lang.String delimiter)
protected void doWrite(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
AbstractGPFDistMessageHandlerMessage in its writer.doWrite in class AbstractGPFDistMessageHandlermessage - the message to writejava.lang.Exceptionprotected void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.context.IntegrationObjectSupportjava.lang.Exceptionprotected void doStart()
AbstractGPFDistMessageHandlerAbstractGPFDistMessageHandler.lifecycleLock.doStart in class AbstractGPFDistMessageHandlerprotected void doStop()
AbstractGPFDistMessageHandlerAbstractGPFDistMessageHandler.lifecycleLock.doStop in class AbstractGPFDistMessageHandlerpublic void setSqlTaskScheduler(org.springframework.scheduling.TaskScheduler sqlTaskScheduler)
public void setGreenplumLoad(GreenplumLoad greenplumLoad)
public void setRateInterval(int rateInterval)