public abstract class BasicFlowControl extends java.lang.Object implements ProcessingInterface
datasetSend() aufgerufen werden um den Zähler der gesendeten Daten hochzuzählen.
flowControl() kann immer aufgerufen werden bevor ein Datensätze versendet werden würde um den Versand ggf. auszubremsen.| Modifier and Type | Field and Description |
|---|---|
protected long |
_maxDelay
Maximale Zeitdauer in ms für die die Protokollerstellung angehalten werden kann.
|
protected java.util.concurrent.atomic.AtomicBoolean |
_pause
Flußkontrolle.
|
| Constructor and Description |
|---|
BasicFlowControl(long maxDelay,
int timeout,
long initialFlowControl)
Erzeut eine neue Instanz
|
| Modifier and Type | Method and Description |
|---|---|
void |
datasetSend() |
protected void |
flowControl()
Flußkontrolle.
|
void |
flowControl(long numData)
Clientseitige automatische flusskontrolle.
|
protected abstract java.lang.Object |
getClient() |
abstract long |
getJobId()
Gibt die Auftrags-Id zurück
|
int |
getTimeout() |
void |
pauseProcessing()
Versand von Protokolldatensätzen anhalten.
|
void |
resumeProcessing()
Versand von Protokolldatensätzen fortsetzen.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitabort, getJobState, getProtocolId, getStatus, process, stopProtocolTransmissionprotected final java.util.concurrent.atomic.AtomicBoolean _pause
protected final long _maxDelay
public BasicFlowControl(long maxDelay,
int timeout,
long initialFlowControl)
maxDelay - Maximale wartezeit bei manueller Flusskontrolle in mstimeout - Anzahl Minuten ohne Antwort vom Client, nach der die Übertragung getrennt wirdinitialFlowControl - Anzahl initial zu sendende Datensätze bis zu automatische Flusskontrolle den Versand bremstpublic void pauseProcessing()
ProcessingInterfacepauseProcessing in interface ProcessingInterfaceProcessingInterface.pauseProcessing()public void resumeProcessing()
ProcessingInterfaceresumeProcessing in interface ProcessingInterfaceProcessingInterface.resumeProcessing()protected void flowControl()
throws java.lang.InterruptedException
java.lang.InterruptedException - Warten wurde unterbrochen.protected abstract java.lang.Object getClient()
public abstract long getJobId()
ProcessingInterfacegetJobId in interface ProcessingInterfacepublic void flowControl(long numData)
ProcessingInterfaceflowControl in interface ProcessingInterfacenumData - Bis zu welcher Datensatznummer (einfach durchnummeriert) Daten gesendet werden sollen.public void datasetSend()
public int getTimeout()