com.metasolv.nm.collector.file

Class MultiThreadManager

java.lang.Object

com.metasolv.nm.collector.file.MultiThreadManager

All Implemented Interfaces:

java.lang.Runnable

public class MultiThreadManager
extends java.lang.Object
implements java.lang.Runnable

Since:

release specific (what release of product did this appear in)

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.FilenameFilter	actFilter
protected static java.lang.String	BINARY_FTP_TRANSER
protected DCStreamHandler[]	dcStHandls
protected static java.lang.String	DEFAULT_SUFFIX
protected boolean	deleteLocalFiles
protected EINode	eiNode
protected boolean	fdChecked
protected FileEIDuplicateCheck	fileduplicateCheck
protected boolean	fileLevelTransaction
protected java.lang.String	filePatternMode
protected boolean	ftp
protected FtpFileTracker	ftpFileTracker
protected FtpEIManager	ftpManager
protected SMGLock	ioLock
protected boolean	keepTrackOfFiles
protected java.io.File	localDir
protected java.lang.String	localFilePrefix
protected java.lang.String	localFileRegExp
protected java.lang.String	localFileSuffix
protected LoggerIfc	logger
protected java.lang.String[]	name
protected int	numberOfThreads
protected long	pollingInterval
protected static java.lang.String	RECOVERY_FILE_SUFFIX
protected SynchronizedDirectory	sd_localDir
protected EITransport[]	transport
protected boolean	useFtp
protected boolean	useSynchronizedDirectory

Constructor Summary

Constructors

Constructor and Description
MultiThreadManager(EINode eiNode, EITransport[] transport, DCStreamHandler[] dcStHandls, int numThreads, java.io.File localDir, java.lang.String suffix) Constructor used to create an instance of MultiThreadManager in Ascii CC, if files are pushed to a local directory
MultiThreadManager(EINode eiNode, EITransport[] transport, DCStreamHandler[] dcStHandls, int numThreads, FtpFileTracker tracker, SMGLock lock) Constructor used to create an instance of MultiThreadManager in Flexile Ascii CC
MultiThreadManager(EINode eiNode, EITransport[] transport, DCStreamHandler[] dcStHandls, int numThreads, SynchronizedDirectory sd_localDir, java.lang.String suffix) Constructor used to create an instance of MultiThreadManager in Ascii CC, if using Ftp to pull the files

Method Summary

Methods

Modifier and Type	Method and Description
protected java.util.Vector	getFiles()
protected void	initConfig()
boolean	isHealthy()
boolean	isLessThan(java.lang.String value1, java.lang.String value2)
boolean	recoveryFileExists(java.io.File file)
void	run()
void	shutdown()
java.lang.String[]	sortFiles(java.lang.String[] filesToProcess)
void	waitIfThreadsProcessing()

Methods inherited from class java.lang.Object

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

Field Detail

transport

protected EITransport[] transport

dcStHandls

protected DCStreamHandler[] dcStHandls

eiNode

protected EINode eiNode

logger

protected LoggerIfc logger

BINARY_FTP_TRANSER

protected static final java.lang.String BINARY_FTP_TRANSER

See Also:

Constant Field Values

DEFAULT_SUFFIX

protected static final java.lang.String DEFAULT_SUFFIX

See Also:

Constant Field Values

pollingInterval

protected long pollingInterval

localFileRegExp

protected java.lang.String localFileRegExp

localFileSuffix

protected java.lang.String localFileSuffix

localFilePrefix

protected java.lang.String localFilePrefix

filePatternMode

protected java.lang.String filePatternMode

useFtp

protected boolean useFtp

useSynchronizedDirectory

protected boolean useSynchronizedDirectory

fileLevelTransaction

protected boolean fileLevelTransaction

sd_localDir

protected SynchronizedDirectory sd_localDir

localDir

protected java.io.File localDir

actFilter

protected java.io.FilenameFilter actFilter

ftpManager

protected FtpEIManager ftpManager

numberOfThreads

protected int numberOfThreads

ftp

protected boolean ftp

name

protected java.lang.String[] name

ftpFileTracker

protected FtpFileTracker ftpFileTracker

ioLock

protected SMGLock ioLock

fileduplicateCheck

protected FileEIDuplicateCheck fileduplicateCheck

RECOVERY_FILE_SUFFIX

protected static final java.lang.String RECOVERY_FILE_SUFFIX

See Also:

Constant Field Values

fdChecked

protected boolean fdChecked

deleteLocalFiles

protected boolean deleteLocalFiles

keepTrackOfFiles

protected boolean keepTrackOfFiles

Constructor Detail

MultiThreadManager

public MultiThreadManager(EINode eiNode,
                  EITransport[] transport,
                  DCStreamHandler[] dcStHandls,
                  int numThreads,
                  FtpFileTracker tracker,
                  SMGLock lock)
                   throws NodeStartException

Constructor used to create an instance of MultiThreadManager in Flexile Ascii CC

Parameters:

eiNode - Specifies the EINode using this MultiThreadManager

transport - Array or transport - processing threads

dcStHandls - Array of DCStreamHandlers

numThreads - Number of processing threads

tracker - FtpFileTracker used to keep track of files that have been retrieved from a specific FTP server

lock - Used to have synchronized access on FtpFileTracker

Throws:

NodeStartException

MultiThreadManager

public MultiThreadManager(EINode eiNode,
                  EITransport[] transport,
                  DCStreamHandler[] dcStHandls,
                  int numThreads,
                  java.io.File localDir,
                  java.lang.String suffix)
                   throws NodeStartException

Constructor used to create an instance of MultiThreadManager in Ascii CC, if files are pushed to a local directory

Parameters:

eiNode - Specifies the EINode using this MultiThreadManager

transport - Array or transport - processing threads

dcStHandls - Array of DCStreamHandlers

numThreads - Number of processing threads

localDir - Local Directory from which files are processed

suffix - User-specified local file suffix

Throws:

NodeStartException

MultiThreadManager

public MultiThreadManager(EINode eiNode,
                  EITransport[] transport,
                  DCStreamHandler[] dcStHandls,
                  int numThreads,
                  SynchronizedDirectory sd_localDir,
                  java.lang.String suffix)
                   throws NodeStartException

Constructor used to create an instance of MultiThreadManager in Ascii CC, if using Ftp to pull the files

Parameters:

eiNode - Specifies the EINode using this MultiThreadManager

transport - Array or transport - processing threads

dcStHandls - Array of DCStreamHandlers

numThreads - Number of processing threads

sd_localDir - Synchronized Directory from which files are processed

suffix - User-specified local file suffix

Throws:

NodeStartException

Method Detail

initConfig

protected void initConfig()
                   throws NodeStartException

Throws:

NodeStartException

run

public void run()

Specified by:

run in interface java.lang.Runnable

getFiles

protected java.util.Vector getFiles()

shutdown

public void shutdown()

isHealthy

public boolean isHealthy()

sortFiles

public java.lang.String[] sortFiles(java.lang.String[] filesToProcess)

isLessThan

public boolean isLessThan(java.lang.String value1,
                 java.lang.String value2)

waitIfThreadsProcessing

public void waitIfThreadsProcessing()

recoveryFileExists

public boolean recoveryFileExists(java.io.File file)