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

Direct Known Subclasses:

HdfsDataStoreMessageHandler, HdfsPartitionDataStoreMessageHandler

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

Base implementation of Spring Integration MessageHandler handling Message.

Author:

Janne Valkealahti

Field Summary

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 abstract void	doWrite(org.springframework.messaging.Message<?> message) Subclasses need to implement this method to handle Message in its writer.
int	getPhase()
protected void	handleMessageInternal(org.springframework.messaging.Message<?> message)
boolean	isAutoStartup()
boolean	isRunning()
void	setAutoStartup(boolean autoStartup) Sets the auto startup.
void	setPhase(int phase) Sets the phase.
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, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, 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

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 final 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

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

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 abstract void doWrite(org.springframework.messaging.Message<?> message)
                         throws java.lang.Exception

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

Parameters:

message - the message to write

Throws:

java.lang.Exception