|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
de.bsvrz.ars.ars.mgmt.tasks.Task
de.bsvrz.ars.ars.mgmt.tasks.SingleTask
de.bsvrz.ars.ars.mgmt.tasks.SingleClientSenderTask
public abstract class SingleClientSenderTask
Diese Klasse ist die Basis-Klasse aller Single-Tasks, die mit dem DAV kommunizieren.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
protected static AttributeGroup |
atgQuery
Attributgruppe der Archiv-Anfrage und -Antwort. |
protected static DataDescription |
ddResponse
DataDescription der Archiv-Antwort. |
protected Deserializer |
deserializer
|
protected SystemObject |
queryAppObj
Applikations-Objekt des Absenders der Archiv-Anfrage. |
protected int |
queryIdx
Anfrage-Index der anfragenden Applikation zur Archiv-Anfrage. |
static int |
SENDCONTROL_TIMEOUT
Zeit in Millisekunden, die auf eine positive Sendesteuerung gewartet wird |
protected int |
serializerVersion
Serialisiererversion der anfragenden Applikation, mit der auch die Antwort erstellt werden muss. |
protected Object |
syncObj
Spezielles Objekt zur Synchronisiserung. |
Fields inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task |
---|
archMgr, didTree, INDEX_MEMORY_SIZE, isTerminated, logger, persMgr, ringOfDeathListener, taskStepListeners |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Fields inherited from interface de.bsvrz.dav.daf.main.ClientSenderInterface |
---|
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION |
Constructor Summary | |
---|---|
SingleClientSenderTask(ArchiveManager archiveMgr,
RingOfDeathListener rodl,
RingBuffer<ResultData> inputData)
Erzeugt einen neuen SingleClientSenderTask. |
Method Summary | |
---|---|
void |
dataRequest(SystemObject object,
DataDescription dataDescription,
byte state)
|
static void |
getObjectsFromDAV(ClientDavInterface davCon)
In dieser Methode werden alle notwendigen Objekte von DAV geladen. |
protected void |
init(Data data)
Initialisiert den Task fuer eine neue Archivanfrage. |
boolean |
isRequestSupported(SystemObject object,
DataDescription dataDescription)
|
protected ArchiveDataSpecification[] |
parseArchiveDataSpec(Deserializer ds,
ResultData resultData)
|
protected void |
sendErrorResponse(int messageTypeResult,
String errorMessage)
|
protected void |
sendErrorResponse(String errorMessage)
|
protected void |
sendSuccessResponse()
|
protected void |
sendSuccessResponse(int messageTypeResult)
|
protected void |
subscribeSender()
Meldet den Task als Sender fuer Archiv-Antworten an das angegebene Empfaenger-Applikations-Objekt an. |
protected void |
unsubscribeSender()
Meldet den Task als Sender fuer Archiv-Antworten an das angegebene Empfaenger-Applikations-Objekt ab. |
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.SingleTask |
---|
run, work |
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task |
---|
addTaskStepListener, getArchMgr, isTaskTerminated, removeTaskStepListener, suspendTaskIfNecessary, terminateTask |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final int SENDCONTROL_TIMEOUT
protected Object syncObj
protected int serializerVersion
protected static AttributeGroup atgQuery
protected static DataDescription ddResponse
protected SystemObject queryAppObj
protected int queryIdx
protected Deserializer deserializer
Constructor Detail |
---|
public SingleClientSenderTask(ArchiveManager archiveMgr, RingOfDeathListener rodl, RingBuffer<ResultData> inputData) throws ConfigurationException
archiveMgr
- Der Archiv-Manager.rodl
- Der Listener wird benachrichtigt beim Beenden der Task.inputData
- Eingangswarteschlange
ConfigurationException
Method Detail |
---|
public static void getObjectsFromDAV(ClientDavInterface davCon) throws ConfigurationException
davCon
- Verbindung zum Datenverteiler
ConfigurationException
protected void init(Data data) throws NoSuchVersionException
NoSuchVersionException
protected void sendErrorResponse(String errorMessage)
protected void sendSuccessResponse()
protected void sendErrorResponse(int messageTypeResult, String errorMessage)
protected void sendSuccessResponse(int messageTypeResult)
protected void subscribeSender() throws ConfigurationException, OneSubscriptionPerSendData
OneSubscriptionPerSendData
ConfigurationException
protected void unsubscribeSender()
public void dataRequest(SystemObject object, DataDescription dataDescription, byte state)
dataRequest
in interface ClientSenderInterface
ClientSenderInterface.dataRequest(SystemObject,DataDescription,byte)
public boolean isRequestSupported(SystemObject object, DataDescription dataDescription)
isRequestSupported
in interface ClientSenderInterface
ClientSenderInterface.isRequestSupported(SystemObject,DataDescription)
protected ArchiveDataSpecification[] parseArchiveDataSpec(Deserializer ds, ResultData resultData) throws Exception
Exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |