de.bsvrz.dav.daf.communication.lowLevel
Class LowLevelCommunication.ReceivingChannel
java.lang.Object
java.lang.Thread
de.bsvrz.dav.daf.communication.lowLevel.LowLevelCommunication.ReceivingChannel
- All Implemented Interfaces:
- Runnable
- Enclosing class:
- LowLevelCommunication
class LowLevelCommunication.ReceivingChannel
- extends Thread
Method Summary |
private boolean |
handleWithoutQueueing(DataTelegram telegram)
Verarbeitung von Telegrammen, die vorrangig berücksichtigt werden müssen. |
private DataTelegram |
readNextTelegram()
Liest ein Telegramm von der Kommunikationsverbindung ein. |
void |
run()
Empfängt Telegramme von der Kommunikationsverbindung und gibt sie zur Verarbeitung weiter |
Methods inherited from class java.lang.Thread |
activeCount, checkAccess, 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 |
LowLevelCommunication.ReceivingChannel
private LowLevelCommunication.ReceivingChannel()
readNextTelegram
private DataTelegram readNextTelegram()
throws IOException
- Liest ein Telegramm von der Kommunikationsverbindung ein.
- Returns:
- gelesenes Telegramm
- Throws:
IOException
- Wenn beim Lesen Fehler aufgetreten sind.
IllegalArgumentException
- Wenn ein Telegramm mit einem unbekannten Typ empfangen wurde
handleWithoutQueueing
private boolean handleWithoutQueueing(DataTelegram telegram)
- Verarbeitung von Telegrammen, die vorrangig berücksichtigt werden müssen.
- Parameters:
telegram
- Zu verarbeitendes Telegramm.
- Returns:
true
, falls das Telegramm verarbeitet wurde; false
falls das Telegramm nicht verarbeitet wurde.
run
public final void run()
- Empfängt Telegramme von der Kommunikationsverbindung und gibt sie zur Verarbeitung weiter
- Specified by:
run
in interface Runnable
- Overrides:
run
in class Thread