org.springframework.xd.integration.hadoop.outbound

Class HdfsStoreMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler

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.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent, org.springframework.messaging.MessageHandler

public class HdfsStoreMessageHandler
extends org.springframework.integration.handler.AbstractMessageHandler
implements org.springframework.context.SmartLifecycle

Spring Integration MessageHandler handling Message writing into hdfs using DataStoreWriter.

Author:

Janne Valkealahti

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
HdfsStoreMessageHandler()

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) Writes a Message into a DataStoreWriter.
int	getPhase()
protected void	handleMessageInternal(org.springframework.messaging.Message<?> message)
boolean	isAutoStartup()
boolean	isRunning()
protected void	onInit()
void	setAutoStartup(boolean autoStartup) Sets the auto startup.
void	setPhase(int phase) Sets the phase.
void	setStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter) Sets the store writer.
void	start()
void	stop()
void	stop(java.lang.Runnable callback)

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

getComponentType, getOrder, handleMessage, setOrder, setShouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, 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

HdfsStoreMessageHandler

public HdfsStoreMessageHandler()

Method Detail

isAutoStartup

public final boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

getPhase

public final int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

isRunning

public final boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public final void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public final void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

stop

public final void stop(java.lang.Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

handleMessageInternal

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

Specified by:

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

Throws:

java.lang.Exception

onInit

protected void onInit()
               throws java.lang.Exception

Overrides:

onInit in class org.springframework.integration.context.IntegrationObjectSupport

Throws:

java.lang.Exception

setAutoStartup

public void setAutoStartup(boolean autoStartup)

Sets the auto startup.

Parameters:

autoStartup - the new auto startup

See Also:

SmartLifecycle

setPhase

public void setPhase(int phase)

Sets the phase.

Parameters:

phase - the new phase

See Also:

SmartLifecycle

setStoreWriter

public void setStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter)

Sets the store writer.

Parameters:

storeWriter - the new store writer

doStart

protected void doStart()

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

doStop

protected void doStop()

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

doWrite

protected void doWrite(org.springframework.messaging.Message<?> message)

Writes a Message into a DataStoreWriter.

Parameters:

message - the message