Package com.nt.udc.ndk.processor

Class FtpOutProcessor

java.lang.Object

com.nt.udc.ndk.processor.DataSyncProcessor

com.nt.udc.ndk.processor.FtpOutProcessor

All Implemented Interfaces:

CheckpointUserIfc, BaseDataProcessorIfc, DataReceiverProcessorIfc, FTPTransferNotificationIfc

public class FtpOutProcessor
extends DataSyncProcessor
implements CheckpointUserIfc, FTPTransferNotificationIfc

Constructor Summary

Constructors

Constructor	Description
FtpOutProcessor(PartitionedDCNode node)

Method Summary

Modifier and Type	Method	Description
void	clearCheckpointData()
void	flushCheckpoint(BaseCheckpointData cp)
BaseCheckpointData	generateEmptyCheckpointData()
BaseCheckpointData	getCheckpointData()
String	getIdentifier()
void	initialize()
void	preTransferNotification()
void	processData(Object dataItem)	Implement this to perform work on incoming data.
void	restoreCheckpoint(BaseCheckpointData cp)
void	shutdown()

Methods inherited from class com.nt.udc.ndk.processor.DataSyncProcessor

removeProvider, setProvider

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FtpOutProcessor

public FtpOutProcessor(PartitionedDCNode node)
                throws NodeStartException

Throws:

NodeStartException

Method Details

initialize

public void initialize()

Specified by:

initialize in interface BaseDataProcessorIfc

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseDataProcessorIfc

Overrides:

shutdown in class DataSyncProcessor

processData

public void processData(Object dataItem)

Description copied from interface: DataReceiverProcessorIfc

Implement this to perform work on incoming data.

Specified by:

processData in interface DataReceiverProcessorIfc

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface CheckpointUserIfc

generateEmptyCheckpointData

public BaseCheckpointData generateEmptyCheckpointData()

Specified by:

generateEmptyCheckpointData in interface CheckpointUserIfc

getCheckpointData

public BaseCheckpointData getCheckpointData()

Specified by:

getCheckpointData in interface CheckpointUserIfc

clearCheckpointData

public void clearCheckpointData()

Specified by:

clearCheckpointData in interface CheckpointUserIfc

flushCheckpoint

public void flushCheckpoint(BaseCheckpointData cp)

Specified by:

flushCheckpoint in interface CheckpointUserIfc

restoreCheckpoint

public void restoreCheckpoint(BaseCheckpointData cp)

Specified by:

restoreCheckpoint in interface CheckpointUserIfc

preTransferNotification

public void preTransferNotification()

Specified by:

preTransferNotification in interface FTPTransferNotificationIfc