public class HdfsWritingMessageHandler
extends org.springframework.integration.handler.AbstractMessageHandler
implements org.springframework.context.SmartLifecycle
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
lifecycleMonitor |
Constructor and Description |
---|
HdfsWritingMessageHandler(HdfsWriterFactory hdfsWriterFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
doWrite(org.springframework.integration.Message<?> message) |
int |
getPhase() |
protected void |
handleMessageInternal(org.springframework.integration.Message<?> message) |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAutoStartup(boolean autoStartup) |
void |
setPhase(int phase) |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
getComponentType, getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString
public HdfsWritingMessageHandler(HdfsWriterFactory hdfsWriterFactory)
protected void handleMessageInternal(org.springframework.integration.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class org.springframework.integration.handler.AbstractMessageHandler
java.lang.Exception
protected void doWrite(org.springframework.integration.Message<?> message)
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public void stop(java.lang.Runnable callback)
stop
in interface org.springframework.context.SmartLifecycle
public int getPhase()
getPhase
in interface org.springframework.context.Phased
public void setPhase(int phase)
public boolean isAutoStartup()
isAutoStartup
in interface org.springframework.context.SmartLifecycle
public void setAutoStartup(boolean autoStartup)