public class DavPublisher extends StatePublisherTask
Modifier and Type | Field and Description |
---|---|
private static boolean |
_archiveAvailable |
private ClientDavInterface |
_davConnection |
private static Debug |
_debug |
private static java.lang.Object |
_lock |
Constructor and Description |
---|
DavPublisher(ClientDavInterface clientDavInterface) |
Modifier and Type | Method and Description |
---|---|
static void |
addClient(ClientDavInterface dav,
SystemObject object,
int protocolVersion)
Fügt einen neuen Client hinzu
|
private static DataDescription |
getDataDescription(ClientDavInterface dav) |
int |
getInterval() |
private static Data |
getNotifyArchiveData(ClientDavInterface dav,
SystemObject object,
int requestId) |
private static Data |
makeData(ClientDavInterface davConnection,
long requestId,
SystemObject client,
byte[] data) |
void |
notifyArchiveAvailable(boolean archiveAvailable)
Wird aufgerufen, wenn sich der Zustand des Archivsystems ändert
|
void |
notifyProtocolRead(long protocolId)
Wird aufgerufen, wenn ein Protokoll den Status von gelesen nach ungelesen ändert
|
void |
notifyProtocolRemoved(long protocolId)
Wird aufgerufen, nachdem ein Protokoll gelöscht wird
|
void |
notifyThreadFinished(ThreadElement threadElement)
Wird aufgerufen, wenn sich ein Auftrag beendet hat
|
static void |
removeClient(SystemObject object) |
private byte[] |
serializeThreadInfo(ThreadElement threadElement) |
protected void |
update(StatePublisher.Status status)
Wird periodisch (siehe
StatePublisherTask.getInterval() ) aufgerufen, um über den aktuellen Status zu informieren |
run, setDataSource
private static final Debug _debug
private static java.lang.Object _lock
private final ClientDavInterface _davConnection
private static boolean _archiveAvailable
public DavPublisher(ClientDavInterface clientDavInterface)
public static void addClient(ClientDavInterface dav, SystemObject object, int protocolVersion)
dav
- object
- Empfänger-Objekt des Clients, an das Benachrichtigungen gesendet werden sollenprotocolVersion
- Protokollversion des Clients (bestimmt unter anderem ob erweiterte Benachrichtigungen an ihn gesendet werden, ab Version 2)private static Data getNotifyArchiveData(ClientDavInterface dav, SystemObject object, int requestId) throws FailureException
FailureException
public static void removeClient(SystemObject object)
private static DataDescription getDataDescription(ClientDavInterface dav)
public int getInterval()
getInterval
in class StatePublisherTask
protected void update(StatePublisher.Status status)
StatePublisherTask
StatePublisherTask.getInterval()
) aufgerufen, um über den aktuellen Status zu informierenupdate
in class StatePublisherTask
status
- aktueller Statuspublic void notifyThreadFinished(ThreadElement threadElement)
StatePublisherTask
notifyThreadFinished
in class StatePublisherTask
threadElement
- Auftragprivate byte[] serializeThreadInfo(ThreadElement threadElement)
public void notifyProtocolRemoved(long protocolId)
StatePublisherTask
notifyProtocolRemoved
in class StatePublisherTask
protocolId
- Protokoll-Idpublic void notifyProtocolRead(long protocolId)
StatePublisherTask
notifyProtocolRead
in class StatePublisherTask
protocolId
- Protokoll-Idpublic void notifyArchiveAvailable(boolean archiveAvailable)
StatePublisherTask
notifyArchiveAvailable
in class StatePublisherTask
archiveAvailable
- Ob das Archivsystem verfügbar ist, oder nichtprivate static Data makeData(ClientDavInterface davConnection, long requestId, SystemObject client, byte[] data) throws FailureException
FailureException