Class NamedConcurrentQueue

  • All Implemented Interfaces:
    MessagingQueue

    public class NamedConcurrentQueue
    extends java.lang.Object
    implements MessagingQueue
    Implementierung einer benamten Queue, die jedoch mittels ThreadPoolExecutor multi-threaded arbeitet.
    • Constructor Summary

      Constructors 
      Constructor Description
      NamedConcurrentQueue​(java.lang.String name)
      ct.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()
      Schliesst die Queue und sendet alle noch offenen Nachrichten.
      void flush()
      Sendet alle noch offenen Nachrichten.
      int getQueueSize()
      Liefert die aktuelle Anzahl noch zuzustellender Nachrichten.
      void queueMessage​(Message message)
      Stellt eine Nachricht in die Queue.
      void registerMessageConsumer​(MessageConsumer consumer)
      Registriert einen Nachrichten-Consumer manuell in der Queue.
      void sendMessage​(Message message)
      Sendet eine Nachricht asynchron an alle Nachrichtenverbraucher der Queue.
      void sendSyncMessage​(Message message)
      Sendet eine Nachricht synchron an alle Nachrichtenverbraucher der Queue.
      void unRegisterMessageConsumer​(MessageConsumer consumer)
      Entfernt einen Nachrichten-Consumer aus der Queue.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait