Package org.apache.logging.log4j.core.util

Class WatchManager

java.lang.Object

org.apache.logging.log4j.core.AbstractLifeCycle

org.apache.logging.log4j.core.util.WatchManager

All Implemented Interfaces:

LifeCycle, LifeCycle2

public class WatchManager
extends AbstractLifeCycle

Manages FileWatchers.

See Also:

FileWatcher, ConfigurationScheduler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	WatchManager.ConfigurationMonitor
private static class	WatchManager.LocalUUID
private class	WatchManager.WatchRunnable

Nested classes/interfaces inherited from interface org.apache.logging.log4j.core.LifeCycle

LifeCycle.State

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.List<WatchEventService>	eventServiceList
private java.util.concurrent.ScheduledFuture<?>	future
private java.util.UUID	id
private int	intervalSeconds
private static Logger	logger
private ConfigurationScheduler	scheduler
private java.util.concurrent.ConcurrentMap<Source,WatchManager.ConfigurationMonitor>	watchers

Fields inherited from class org.apache.logging.log4j.core.AbstractLifeCycle

DEFAULT_STOP_TIMEOUT, DEFAULT_STOP_TIMEUNIT, LOGGER

Constructor Summary

Constructors

Constructor	Description
WatchManager(ConfigurationScheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	checkFiles()
java.util.Map<Source,Watcher>	getConfigurationWatchers()	Return the ConfigurationWaatchers.
java.util.UUID	getId()
int	getIntervalSeconds()	Gets how often this manager checks for file modifications.
java.util.Map<java.io.File,FileWatcher>	getWatchers()	Deprecated. use getConfigurationWatchers.
boolean	hasEventListeners()
private java.lang.String	millisToString(long millis)
void	reset()	Resets all file monitors to their current last modified time.
void	reset(java.io.File file)	Resets the file monitor for the given file being watched to its current last modified time.
void	reset(Source source)	Resets the configuration monitor for the given file being watched to its current last modified time.
void	setIntervalSeconds(int intervalSeconds)
void	start()
boolean	stop(long timeout, java.util.concurrent.TimeUnit timeUnit)	Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
java.lang.String	toString()
void	unwatch(Source source)	Unwatches the given file.
void	unwatchFile(java.io.File file)	Unwatches the given file.
void	watch(Source source, Watcher watcher)	Watches the given file.
void	watchFile(java.io.File file, FileWatcher fileWatcher)	Watches the given file.

Methods inherited from class org.apache.logging.log4j.core.AbstractLifeCycle

equalsImpl, getState, getStatusLogger, hashCodeImpl, initialize, isInitialized, isStarted, isStarting, isStopped, isStopping, setStarted, setStarting, setState, setStopped, setStopping, stop, stop

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static Logger logger

watchers

private final java.util.concurrent.ConcurrentMap<Source,WatchManager.ConfigurationMonitor> watchers

intervalSeconds

private int intervalSeconds

future

private java.util.concurrent.ScheduledFuture<?> future

scheduler

private final ConfigurationScheduler scheduler

eventServiceList

private final java.util.List<WatchEventService> eventServiceList

id

private final java.util.UUID id

Constructor Detail

WatchManager

public WatchManager(ConfigurationScheduler scheduler)

Method Detail

checkFiles

public void checkFiles()

getConfigurationWatchers

public java.util.Map<Source,Watcher> getConfigurationWatchers()

Return the ConfigurationWaatchers.

Returns:

the ConfigurationWatchers.

Since:

2.11.2

getId

public java.util.UUID getId()

getIntervalSeconds

public int getIntervalSeconds()

Gets how often this manager checks for file modifications.

Returns:

how often, in seconds, this manager checks for file modifications.

getWatchers

@Deprecated
public java.util.Map<java.io.File,FileWatcher> getWatchers()

Deprecated.

use getConfigurationWatchers.

Returns a Map of the file watchers.

Returns:

A Map of the file watchers.

hasEventListeners

public boolean hasEventListeners()

millisToString

private java.lang.String millisToString(long millis)

reset

public void reset()

Resets all file monitors to their current last modified time. If this manager does not watch any file, nothing happens.

This allows you to start, stop, reset and start again a manager, without triggering file modified events if the a watched file has changed during the period of time when the manager was stopped.

Since:

2.11.0

reset

public void reset(java.io.File file)

Resets the file monitor for the given file being watched to its current last modified time. If this manager does not watch the given file, nothing happens.

This allows you to start, stop, reset and start again a manager, without triggering file modified events if the given watched file has changed during the period of time when the manager was stopped.

Parameters:

file - the file for the monitor to reset.

Since:

2.11.0

reset

public void reset(Source source)

Resets the configuration monitor for the given file being watched to its current last modified time. If this manager does not watch the given configuration, nothing happens.

This allows you to start, stop, reset and start again a manager, without triggering file modified events if the given watched configuration has changed during the period of time when the manager was stopped.

Parameters:

source - the Source for the monitor to reset.

Since:

2.12.0

setIntervalSeconds

public void setIntervalSeconds(int intervalSeconds)

start

public void start()

Specified by:

start in interface LifeCycle

Overrides:

start in class AbstractLifeCycle

stop

public boolean stop(long timeout,
                    java.util.concurrent.TimeUnit timeUnit)

Description copied from interface: LifeCycle2

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Specified by:

stop in interface LifeCycle2

Overrides:

stop in class AbstractLifeCycle

Parameters:

timeout - the maximum time to wait

timeUnit - the time unit of the timeout argument

Returns:

true if the receiver was stopped cleanly and normally, false otherwise.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

unwatch

public void unwatch(Source source)

Unwatches the given file.

Parameters:

source - the Source to stop watching. the file to stop watching.

Since:

2.12.0

unwatchFile

public void unwatchFile(java.io.File file)

Unwatches the given file.

Parameters:

file - the file to stop watching.

Since:

2.11.0

watch

public void watch(Source source,
                  Watcher watcher)

Watches the given file.

Parameters:

source - the source to watch.

watcher - the watcher to notify of file changes.

watchFile

public void watchFile(java.io.File file,
                      FileWatcher fileWatcher)

Watches the given file.

Parameters:

file - the file to watch.

fileWatcher - the watcher to notify of file changes.