|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.dav.daf.communication.protocol.ClientHighLevelCommunication.SendControlNotifier
private class ClientHighLevelCommunication.SendControlNotifier
Asynchrone Verarbeitung von empfangenen Sendsteuerungstelegrammen. Speichert mit put übergebene Sendesteuerungstelegramme in einer internen Queue, aus der die Telegramme asynchron von einem eigenen Thread ausgelesen und zur Weiterverarbeitung an den SubscriptionsManager weitergegeben werden.
Field Summary | |
---|---|
private UnboundedQueue<RequestSenderDataTelegram> |
_telegrams
|
Constructor Summary | |
---|---|
ClientHighLevelCommunication.SendControlNotifier()
Der Konstruktor erzeugt die interne Queue und den Thread zur Verarbeitung der Telegramme. |
Method Summary | |
---|---|
void |
close()
Signalisiert dem Thread zur Verarbeitung der Telegramme, dass keine weiteren Telegramme verarbeitet werden müssen und der Thread sich beenden kann. |
void |
put(RequestSenderDataTelegram telegram)
Speichert das übergebene Telegramm in der Queue zur asynchronen Verarbeitung. |
void |
run()
Methode zur asynchronen Verarbeitung von gespeicherten Telegrammen durch einen eigenen Thread. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private UnboundedQueue<RequestSenderDataTelegram> _telegrams
Constructor Detail |
---|
public ClientHighLevelCommunication.SendControlNotifier()
Method Detail |
---|
public void put(RequestSenderDataTelegram telegram)
telegram
- Zu verarbeitendes Sendesteuerungstelegramm.public void close()
public void run()
run
in interface Runnable
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |