com.highqsoft.importtool

Class ObserverCoordinator

java.lang.Object

java.lang.Thread

com.highqsoft.importtool.ObserverCoordinator

All Implemented Interfaces:

FilePollerListenerInterface, java.io.FileFilter, java.lang.Runnable, java.util.EventListener

public class ObserverCoordinator
extends java.lang.Thread
implements FilePollerListenerInterface, java.io.FileFilter

Coordinates the watched import directories. The ObserverCoordinator watches a single directory. It is called whenever a subdirectory of the watched directory is created, deleted or renamed.

The subdirectories are watched by JobCoordinators. When a new subdirectory is created it gets watched by its own JobCoordinator. When a subdirectory is deleted the JobCoordinator of this directory is destroyed. When a subdirectory is renamed the JobCoordinator for the old name is removed and a new one is created.

Since:

$Date: 2017/04/06 13:29:19 $

Version:

$Revision: 4.18 $

Author:

Markus Schuldlos

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ObserverCoordinator(java.lang.String path) Create the ObserverCoordinator and add a Watch for all subdirectories.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	accept(java.io.File pathname) Filter which accepts only directories.
void	fileChange(FilePollerEvent event) Listener for FilePollerEvents.
static boolean	isReconnecting()
static void	shutdown()
void	start(FileObserver fileObserver)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ObserverCoordinator

public ObserverCoordinator(java.lang.String path)

Create the ObserverCoordinator and add a Watch for all subdirectories.

Parameters:

fileObserver - Name of directory to watch.

path - Root directory of watched paths

Method Detail

start

public void start(FileObserver fileObserver)

fileChange

public void fileChange(FilePollerEvent event)

Listener for FilePollerEvents. The listener is called whenever a change in the watched Directory occours.

Specified by:

fileChange in interface FilePollerListenerInterface

Parameters:

event - The event of the change.

See Also:

#com.highqsoft.util.FilePollerEvent, #com.highqsoft.util.FilePoller

accept

public boolean accept(java.io.File pathname)

Filter which accepts only directories.

Specified by:

accept in interface java.io.FileFilter

Parameters:

pathname - Name of path to check

Returns:

true if pathname is a directory, false if not

isReconnecting

public static boolean isReconnecting()

shutdown

public static void shutdown()