de.bsvrz.dav.daf.communication.protocol
Class ClientHighLevelCommunication.SendControlNotifier

java.lang.Object
  extended by de.bsvrz.dav.daf.communication.protocol.ClientHighLevelCommunication.SendControlNotifier
All Implemented Interfaces:
Runnable
Enclosing class:
ClientHighLevelCommunication

private class ClientHighLevelCommunication.SendControlNotifier
extends Object
implements Runnable

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

_telegrams

private UnboundedQueue<RequestSenderDataTelegram> _telegrams
Constructor Detail

ClientHighLevelCommunication.SendControlNotifier

public ClientHighLevelCommunication.SendControlNotifier()
Der Konstruktor erzeugt die interne Queue und den Thread zur Verarbeitung der Telegramme.

Method Detail

put

public void put(RequestSenderDataTelegram telegram)
Speichert das übergebene Telegramm in der Queue zur asynchronen Verarbeitung.

Parameters:
telegram - Zu verarbeitendes Sendesteuerungstelegramm.

close

public void close()
Signalisiert dem Thread zur Verarbeitung der Telegramme, dass keine weiteren Telegramme verarbeitet werden müssen und der Thread sich beenden kann.


run

public void run()
Methode zur asynchronen Verarbeitung von gespeicherten Telegrammen durch einen eigenen Thread.

Specified by:
run in interface Runnable