WatchService
logic in the FileReadingMessageSource
.
Will be removed in Spring Integration 5.0.@Deprecated @UsesJava7 public class WatchServiceDirectoryScanner extends DefaultDirectoryScanner implements org.springframework.context.SmartLifecycle
WatchService
.
The initial state of the directory is collected during start()
. Subsequent
polls return new files as reported by ENTRY_CREATE
events.
While initially walking the directory, any subdirectories encountered are registered to watch for creation events.
If subdirectories are subsequently added, they are walked and registered for new creation events, too.
When a StandardWatchEventKinds.OVERFLOW
WatchKey
event is occurred,
the directory
is rescanned to avoid the loss for any new entries according
to the "missed events" logic around StandardWatchEventKinds.OVERFLOW
.
Constructor and Description |
---|
WatchServiceDirectoryScanner(java.lang.String directory)
Deprecated.
Construct an instance for the given directory.
|
Modifier and Type | Method and Description |
---|---|
int |
getPhase()
Deprecated.
|
boolean |
isAutoStartup()
Deprecated.
|
boolean |
isRunning()
Deprecated.
|
protected java.io.File[] |
listEligibleFiles(java.io.File directory)
Deprecated.
Subclasses may refine the listing strategy by overriding this method.
|
void |
setAutoStartup(boolean autoStartup)
Deprecated.
|
void |
setPhase(int phase)
Deprecated.
see
getPhase() |
void |
setRunning(boolean running)
Deprecated.
|
void |
start()
Deprecated.
|
void |
stop()
Deprecated.
|
void |
stop(java.lang.Runnable callback)
Deprecated.
|
public WatchServiceDirectoryScanner(java.lang.String directory)
directory
- the directory.public int getPhase()
getPhase
in interface org.springframework.context.Phased
public void setPhase(int phase)
getPhase()
phase
- the phase.public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public void setRunning(boolean running)
running
- true if running.isRunning()
public boolean isAutoStartup()
isAutoStartup
in interface org.springframework.context.SmartLifecycle
public void setAutoStartup(boolean autoStartup)
autoStartup
- true to auto start.isAutoStartup()
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public void stop(java.lang.Runnable callback)
stop
in interface org.springframework.context.SmartLifecycle
protected java.io.File[] listEligibleFiles(java.io.File directory)
DefaultDirectoryScanner
listEligibleFiles
in class DefaultDirectoryScanner
directory
- root directory to use for listing