com.metasolv.nm.collector.file

Class FtpFileTracker

java.lang.Object

com.metasolv.nm.collector.file.FtpFileTracker

public class FtpFileTracker
extends java.lang.Object

Used to keep track of files that have been retrieved from a specific FTP server. This will ensure that a file is not retrieved more than once. This class is based on the SmdrFtpFileTracker class that was designed for the SMDR cartridge.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.PrintWriter	currentWriter
protected java.lang.ThreadLocal<java.text.SimpleDateFormat>	dateFmt
protected int	daysToTrack
static int	DEFAULT_DAYS_TO_TRACK
protected boolean	keepRunning
protected java.lang.Thread	oldTrackerFileRemoverThread
protected java.io.File	scratchDirectory
protected java.util.TreeSet	sortedFilenameSet
protected java.util.ArrayList	trackerFileList
protected java.lang.String	trackerFilePrefix

Constructor Summary

Constructors

Constructor and Description
FtpFileTracker(java.lang.String filePrefix, java.io.File scratchDirectory, int days)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	contains(java.lang.String ipAddress, java.lang.String filename) Search this tracker for the given IP address + file name combination.
void	flushOldRecords()
void	init()
protected void	initSortedFilenameSet()
protected void	initTrackerFileList(java.util.Calendar cal, int daysToTrack)
protected java.lang.String	makeTodayTrackerFilename()
protected java.lang.String	makeTrackerFilename(java.util.Date date)
protected void	readTrackerFile(java.io.File inputTrackerFile, java.util.TreeSet filenameSet)
protected void	removeOutdatedTrackerFiles()
void	shutdown()
boolean	track(java.lang.String ipAddress, java.lang.String filename) Adds the specified IP address and file name to this tracker if it is not already present.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_DAYS_TO_TRACK

public static final int DEFAULT_DAYS_TO_TRACK

See Also:

Constant Field Values

sortedFilenameSet

protected java.util.TreeSet sortedFilenameSet

trackerFilePrefix

protected java.lang.String trackerFilePrefix

dateFmt

protected java.lang.ThreadLocal<java.text.SimpleDateFormat> dateFmt

trackerFileList

protected java.util.ArrayList trackerFileList

currentWriter

protected java.io.PrintWriter currentWriter

scratchDirectory

protected java.io.File scratchDirectory

oldTrackerFileRemoverThread

protected java.lang.Thread oldTrackerFileRemoverThread

keepRunning

protected boolean keepRunning

daysToTrack

protected int daysToTrack

Constructor Detail

FtpFileTracker

public FtpFileTracker(java.lang.String filePrefix,
              java.io.File scratchDirectory,
              int days)

Method Detail

shutdown

public void shutdown()

track

public boolean track(java.lang.String ipAddress,
            java.lang.String filename)

Adds the specified IP address and file name to this tracker if it is not already present. The information will be saved to file.

Parameters:

ipAddress - IP address to be added to this tracker.

filename - file name to be added to this tracker.

Returns:

true if the tracker did not already contain the specified file name.

contains

public boolean contains(java.lang.String ipAddress,
               java.lang.String filename)

Search this tracker for the given IP address + file name combination.

Parameters:

ipAddress - IP address to be checked within this tracker.

filename - file name to be checked within this tracker.

Returns:

true if the tracker contains this file name.

flushOldRecords

public void flushOldRecords()
                     throws java.io.IOException

Throws:

java.io.IOException

makeTodayTrackerFilename

protected java.lang.String makeTodayTrackerFilename()

makeTrackerFilename

protected java.lang.String makeTrackerFilename(java.util.Date date)

readTrackerFile

protected void readTrackerFile(java.io.File inputTrackerFile,
                   java.util.TreeSet filenameSet)

init

public void init()
          throws java.io.IOException

Throws:

java.io.IOException

initTrackerFileList

protected void initTrackerFileList(java.util.Calendar cal,
                       int daysToTrack)

removeOutdatedTrackerFiles

protected void removeOutdatedTrackerFiles()

initSortedFilenameSet

protected void initSortedFilenameSet()