Package de.willuhn.jameica.messaging
Class NamedQueue
- java.lang.Object
-
- de.willuhn.jameica.messaging.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.
-
-
-
Method Detail
-
getName
public java.lang.String getName()
Liefert den Namen der Queue.- Returns:
- Name der Queue.
-
getQueueSize
public int getQueueSize()
Description copied from interface:MessagingQueue
Liefert die aktuelle Anzahl noch zuzustellender Nachrichten.- Specified by:
getQueueSize
in interfaceMessagingQueue
- Returns:
- aktuelle Queue-Groesse.
- See Also:
MessagingQueue.getQueueSize()
-
registerMessageConsumer
public void registerMessageConsumer(MessageConsumer consumer)
Description copied from interface:MessagingQueue
Registriert einen Nachrichten-Consumer manuell in der Queue.- Specified by:
registerMessageConsumer
in interfaceMessagingQueue
- Parameters:
consumer
- zu registrierender Consumer.- See Also:
MessagingQueue.registerMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)
-
unRegisterMessageConsumer
public void unRegisterMessageConsumer(MessageConsumer consumer)
Description copied from interface:MessagingQueue
Entfernt einen Nachrichten-Consumer aus der Queue.- Specified by:
unRegisterMessageConsumer
in interfaceMessagingQueue
- Parameters:
consumer
- zu entfernender Consumer.- See Also:
MessagingQueue.unRegisterMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)
-
queueMessage
public void queueMessage(Message message)
Description copied from interface:MessagingQueue
Stellt eine Nachricht in die Queue. Dort bleibt sie solange, bis ein Consumer dafuer vorhanden ist.- Specified by:
queueMessage
in interfaceMessagingQueue
- Parameters:
message
- die zu versendende Nachricht.- See Also:
MessagingQueue.queueMessage(de.willuhn.jameica.messaging.Message)
-
close
public void close()
Description copied from interface:MessagingQueue
Schliesst die Queue und sendet alle noch offenen Nachrichten.- Specified by:
close
in interfaceMessagingQueue
- See Also:
MessagingQueue.close()
-
flush
public void flush()
Description copied from interface:MessagingQueue
Sendet alle noch offenen Nachrichten. Die Funktion kehrt erst zurueck, nachdem alle Nachrichten zugestellt wurden.- Specified by:
flush
in interfaceMessagingQueue
- See Also:
MessagingQueue.flush()
-
sendMessage
public void sendMessage(Message message)
Description copied from interface:MessagingQueue
Sendet eine Nachricht asynchron an alle Nachrichtenverbraucher der Queue.- Specified by:
sendMessage
in interfaceMessagingQueue
- Parameters:
message
- die zu versendende Nachricht.- See Also:
MessagingQueue.sendMessage(de.willuhn.jameica.messaging.Message)
-
sendSyncMessage
public void sendSyncMessage(Message message)
Description copied from interface:MessagingQueue
Sendet eine Nachricht synchron an alle Nachrichtenverbraucher der Queue.- Specified by:
sendSyncMessage
in interfaceMessagingQueue
- Parameters:
message
- die zu versendende Nachricht.- See Also:
MessagingQueue.sendSyncMessage(de.willuhn.jameica.messaging.Message)
-
-