public class StatePublisher
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
StatePublisher.Status
Speichert Informationen über Threads, die laufen und sich in der Warteschlange befinden
|
Modifier and Type | Field and Description |
---|---|
private boolean |
_archiveAvailable |
private ArchiveAvailabilityListener |
_archiveListener |
private java.util.Set<ArchiveRequestManager> |
_archiveRequesters |
private ClientDavInterface |
_dav |
private static Debug |
_debug |
private java.util.List<StatePublisherTask> |
_publishers
Liste mit Veröffentlichungs-Modulen, die den Threadstatus über Konsole oder Datenverteiler veröffentlichen
|
private java.util.Map<ThreadPool,java.lang.String> |
_threadPoolsAndNames
Map mit überwachten Thread-Pools (Value ist der Name des Threadpools)
|
private static ThreadPool[] |
EMPTY_ARRAY
Leeres Hilfsarray für toArray()-Aufruf
|
private static java.util.IdentityHashMap<ClientDavInterface,StatePublisher> |
INSTANCE_MAP
Singleton-Instanz dieser Klasse
|
Modifier | Constructor and Description |
---|---|
private |
StatePublisher(ClientDavInterface dav) |
Modifier and Type | Method and Description |
---|---|
private void |
addPublisher(StatePublisherTask publishTask) |
static StatePublisher |
getInstance(ClientDavInterface dav)
Gibt den StatePublisher zurück
|
StatePublisher.Status |
getStatus() |
void |
notifyArchiveAvailable(boolean archiveAvailable)
Wird aufgerufen, wenn sich der Zustand des Archivsystems ändert
|
void |
notifyProtocolRead(long protocolId)
Wird aufgerufen, wenn ein Protokoll gelesen wurde
|
void |
notifyProtocolRemoved(long protocolId)
Wird aufgerufen, wenn ein Protokoll gelöscht wurde
|
void |
notifyThreadFinished(ThreadElement threadElement)
Wird aufgerufen, wenn sich ein Thread beendet hat
|
private void |
refreshArchiveListeners() |
void |
registerThreadPool(ThreadPool threadPool,
java.lang.String name)
Meldet einen ThreadPool an, dessen Thread-Status in Zukunft durch den StatePublisher publiziert wird
|
java.lang.String |
toString() |
private static final java.util.IdentityHashMap<ClientDavInterface,StatePublisher> INSTANCE_MAP
private static final ThreadPool[] EMPTY_ARRAY
private final java.util.List<StatePublisherTask> _publishers
private final java.util.Map<ThreadPool,java.lang.String> _threadPoolsAndNames
private final java.util.Set<ArchiveRequestManager> _archiveRequesters
private static final Debug _debug
private final ClientDavInterface _dav
private ArchiveAvailabilityListener _archiveListener
private boolean _archiveAvailable
private StatePublisher(ClientDavInterface dav)
public static StatePublisher getInstance(ClientDavInterface dav)
dav
- private void refreshArchiveListeners()
public void registerThreadPool(ThreadPool threadPool, java.lang.String name)
threadPool
- ThreadPoolname
- name des ThreadPoolsprivate void addPublisher(StatePublisherTask publishTask)
public StatePublisher.Status getStatus()
public void notifyThreadFinished(ThreadElement threadElement)
threadElement
- Threadpublic void notifyProtocolRemoved(long protocolId)
protocolId
- Protokoll-IDpublic void notifyProtocolRead(long protocolId)
protocolId
- Protokoll-IDpublic void notifyArchiveAvailable(boolean archiveAvailable)
archiveAvailable
- Ob das Archivsystem verfügbar ist, oder nichtpublic java.lang.String toString()
toString
in class java.lang.Object