Package org.chenile.filewatch.handler

Class FileProcessor

java.lang.Object

org.chenile.filewatch.handler.FileProcessor

public class FileProcessor
extends Object

FileProcessor knows to handle each file that was discovered by the file watcher This would process the file and finally dispose it off from the watched folder to the processed folder. The processor only starts reading with a header file. The header file is read for the following reasons:

1. To obtain all the header records that are required to call a particular service
2. To obtain the pointer to the actual file and encoding type
3. To determine if the actual file has been up-loaded completely into the watched folder. It is assumed that the header file will be uploaded only after the actual file has been uploaded. Also, the last property of the header file should be the last line of the header file. Unless that property is written to, file processor will not process the file.

Author:

Raja Shankar Kolluru

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACTUAL_FILE_ENCODING
static final String	ACTUAL_FILE_NAME
private ChenileEntryPoint	chenileEntryPoint
private FileWatchEventLogger	eventLogger
static final String	HEADER_EXTENSION
static final String	LAST_PROPERTY
private Path	processedDir

Constructor Summary

Constructors

Constructor	Description
FileProcessor()

Method Summary

Modifier and Type	Method	Description
private void	copyHeadersToExchange(ChenileExchange exchange, Properties headers)
private Properties	extractHeaders(Path file)
private Iterable<Object>	fileReader(FileWatchDefinition fileWatchDefinition, Path file, String encodingType)
private void	invokeServicesForFile(FileWatchDefinition fileWatchDefinition, Path file, Properties headers)
private void	invokeServicesPerRecord(FileWatchDefinition fileWatchDefinition, Object record, Properties headers)
private void	move(Path file)
private void	moveFilesToProcessed(Path headerFilename, Path recordsFile)
void	processFile(FileWatchDefinition fileWatchDefinition, Path fileDiscovered, Path processedDir)

Methods inherited from class java.lang.Object

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

Field Details

ACTUAL_FILE_NAME

public static final String ACTUAL_FILE_NAME

See Also:

• Constant Field Values

ACTUAL_FILE_ENCODING

public static final String ACTUAL_FILE_ENCODING

See Also:

• Constant Field Values

HEADER_EXTENSION

public static final String HEADER_EXTENSION

See Also:

• Constant Field Values

LAST_PROPERTY

public static final String LAST_PROPERTY

See Also:

• Constant Field Values

chenileEntryPoint

@Autowired
private ChenileEntryPoint chenileEntryPoint

eventLogger

@Autowired
private FileWatchEventLogger eventLogger

processedDir

private Path processedDir

Constructor Details

FileProcessor

public FileProcessor()

Method Details

processFile

public void processFile(FileWatchDefinition fileWatchDefinition,
 Path fileDiscovered,
 Path processedDir)

moveFilesToProcessed

private void moveFilesToProcessed(Path headerFilename,
 Path recordsFile)

move

private void move(Path file)

extractHeaders

private Properties extractHeaders(Path file)

invokeServicesForFile

private void invokeServicesForFile(FileWatchDefinition fileWatchDefinition,
 Path file,
 Properties headers)

fileReader

private Iterable<Object> fileReader(FileWatchDefinition fileWatchDefinition,
 Path file,
 String encodingType)
                             throws Exception

Throws:

Exception

invokeServicesPerRecord

private void invokeServicesPerRecord(FileWatchDefinition fileWatchDefinition,
 Object record,
 Properties headers)

copyHeadersToExchange

private void copyHeadersToExchange(ChenileExchange exchange,
 Properties headers)