org.springframework.xd.integration.hadoop.outbound

Class HdfsDataStoreMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

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

org.springframework.xd.integration.hadoop.outbound.HdfsDataStoreMessageHandler

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 HdfsDataStoreMessageHandler
extends HdfsStoreMessageHandler

Spring Integration MessageHandler handling Message writing into hdfs using DataStoreWriter.

Author:

Janne Valkealahti

Field Summary

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
HdfsDataStoreMessageHandler(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter) Instantiates a new hdfs data store message handler.

Method Summary

Methods

Modifier and Type	Method and Description
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()

Methods inherited from class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler

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

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

HdfsDataStoreMessageHandler

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

Instantiates a new hdfs data store message handler.

Parameters:

storeWriter - the store writer

Method Detail

onInit

protected void onInit()
               throws java.lang.Exception

Overrides:

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

Throws:

java.lang.Exception

doStop

protected void doStop()

Description copied from class: HdfsStoreMessageHandler

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

Overrides:

doStop in class HdfsStoreMessageHandler

doWrite

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

Description copied from class: HdfsStoreMessageHandler

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

Specified by:

doWrite in class HdfsStoreMessageHandler

Parameters:

message - the message to write

Throws:

java.lang.Exception