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 and Description
FtpOutProcessor(PartitionedDCNode node)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearCheckpointData()
void	flushCheckpoint(BaseCheckpointData cp)
BaseCheckpointData	generateEmptyCheckpointData()
BaseCheckpointData	getCheckpointData()
java.lang.String	getIdentifier()
void	initialize()
void	preTransferNotification()
void	processData(java.lang.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 Detail

FtpOutProcessor

public FtpOutProcessor(PartitionedDCNode node)
                throws NodeStartException

Throws:

NodeStartException

Method Detail

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(java.lang.Object dataItem)

Description copied from interface: DataReceiverProcessorIfc

Implement this to perform work on incoming data.

Specified by:

processData in interface DataReceiverProcessorIfc

getIdentifier

public java.lang.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