Module de.thjom.java.systemd

Package de.thjom.java.systemd

Class UnitMonitor

java.lang.Object

de.thjom.java.systemd.AbstractAdapter

de.thjom.java.systemd.UnitMonitor

All Implemented Interfaces:

UnitStateNotifier

Direct Known Subclasses:

UnitNameMonitor, UnitTypeMonitor

abstract class UnitMonitor
extends AbstractAdapter
implements UnitStateNotifier

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	UnitMonitor.ReloadingHandler
class	UnitMonitor.UnitFilesChangedHandler

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	ACTIVE_STATE
protected static final String	ERROR_MSG_MONITOR_REFRESH
private static final String	LOAD_STATE
protected final org.slf4j.Logger	log
protected final Manager	manager
protected final ConcurrentMap<String,Unit>	monitoredUnits
private Timer	pollingTimer
protected UnitMonitor.ReloadingHandler	reloadingHandler
private static final String	SUB_STATE
protected UnitMonitor.UnitFilesChangedHandler	unitFilesChangedHandler
protected final List<UnitMonitorListener>	unitMonitorListeners

Fields inherited from class de.thjom.java.systemd.AbstractAdapter

unitStateListeners

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UnitMonitor(Manager manager)

Method Summary

Modifier and Type	Method	Description
void	addDefaultHandlers()
<T extends org.freedesktop.dbus.messages.DBusSignal> void	addHandler(Class<T> type, org.freedesktop.dbus.interfaces.DBusSigHandler<T> handler)
void	addListener(UnitMonitorListener listener)
protected org.freedesktop.dbus.interfaces.DBusSigHandler<org.freedesktop.dbus.interfaces.Properties.PropertiesChanged>	createStateHandler()
protected Timer	createTimer()
protected Optional<Unit>	findMonitoredUnit(String escapedUnitName)
Optional<Unit>	getMonitoredUnit(String unitName)
Collection<Unit>	getMonitoredUnits()
boolean	monitorsUnit(String unitName)
abstract void	refresh()
void	removeDefaultHandlers()
<T extends org.freedesktop.dbus.messages.DBusSignal> void	removeHandler(Class<T> type, org.freedesktop.dbus.interfaces.DBusSigHandler<T> handler)
void	removeListener(UnitMonitorListener listener)
abstract void	reset()
void	startPolling(long delay, long period)
void	stopPolling()

Methods inherited from class de.thjom.java.systemd.AbstractAdapter

addListener, removeListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.thjom.java.systemd.UnitStateNotifier

addListener, removeListener

Field Details

ERROR_MSG_MONITOR_REFRESH

protected static final String ERROR_MSG_MONITOR_REFRESH

See Also:

• Constant Field Values

ACTIVE_STATE

private static final String ACTIVE_STATE

See Also:

• Constant Field Values

LOAD_STATE

private static final String LOAD_STATE

See Also:

• Constant Field Values

SUB_STATE

private static final String SUB_STATE

See Also:

• Constant Field Values

log

protected final org.slf4j.Logger log

manager

protected final Manager manager

monitoredUnits

protected final ConcurrentMap<String,Unit> monitoredUnits

unitMonitorListeners

protected final List<UnitMonitorListener> unitMonitorListeners

reloadingHandler

protected UnitMonitor.ReloadingHandler reloadingHandler

unitFilesChangedHandler

protected UnitMonitor.UnitFilesChangedHandler unitFilesChangedHandler

pollingTimer

private Timer pollingTimer

Constructor Details

UnitMonitor

protected UnitMonitor(Manager manager)

Method Details

addHandler

public <T extends org.freedesktop.dbus.messages.DBusSignal>
void addHandler(Class<T> type,
 org.freedesktop.dbus.interfaces.DBusSigHandler<T> handler)
         throws org.freedesktop.dbus.exceptions.DBusException

Specified by:

addHandler in class AbstractAdapter

Throws:

org.freedesktop.dbus.exceptions.DBusException

removeHandler

public <T extends org.freedesktop.dbus.messages.DBusSignal>
void removeHandler(Class<T> type,
 org.freedesktop.dbus.interfaces.DBusSigHandler<T> handler)
            throws org.freedesktop.dbus.exceptions.DBusException

Specified by:

removeHandler in class AbstractAdapter

Throws:

org.freedesktop.dbus.exceptions.DBusException

addDefaultHandlers

public void addDefaultHandlers()
                        throws org.freedesktop.dbus.exceptions.DBusException

Throws:

org.freedesktop.dbus.exceptions.DBusException

removeDefaultHandlers

public void removeDefaultHandlers()
                           throws org.freedesktop.dbus.exceptions.DBusException

Throws:

org.freedesktop.dbus.exceptions.DBusException

createStateHandler

protected org.freedesktop.dbus.interfaces.DBusSigHandler<org.freedesktop.dbus.interfaces.Properties.PropertiesChanged> createStateHandler()

Overrides:

createStateHandler in class AbstractAdapter

addListener

public void addListener(UnitMonitorListener listener)

removeListener

public void removeListener(UnitMonitorListener listener)

reset

public abstract void reset()

refresh

public abstract void refresh()
                      throws org.freedesktop.dbus.exceptions.DBusException

Throws:

org.freedesktop.dbus.exceptions.DBusException

startPolling

public void startPolling(long delay,
 long period)

stopPolling

public void stopPolling()

createTimer

protected Timer createTimer()

monitorsUnit

public boolean monitorsUnit(String unitName)

getMonitoredUnit

public Optional<Unit> getMonitoredUnit(String unitName)

findMonitoredUnit

protected Optional<Unit> findMonitoredUnit(String escapedUnitName)

getMonitoredUnits

public Collection<Unit> getMonitoredUnits()