Class NamedQueue

  • All Implemented Interfaces:
    MessagingQueue

    public final class NamedQueue
    extends java.lang.Object
    implements MessagingQueue
    Implementierung einer Queue, die einen Namen hat.
    Author:
    willuhn
    • 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.
      java.lang.String getName()
      Liefert den Namen der Queue.
      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