MessagingQueue
public final class NamedQueue extends java.lang.Object implements MessagingQueue
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.
|
public java.lang.String getName()
public int getQueueSize()
MessagingQueue
getQueueSize
in interface MessagingQueue
MessagingQueue.getQueueSize()
public void registerMessageConsumer(MessageConsumer consumer)
MessagingQueue
registerMessageConsumer
in interface MessagingQueue
consumer
- zu registrierender Consumer.MessagingQueue.registerMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)
public void unRegisterMessageConsumer(MessageConsumer consumer)
MessagingQueue
unRegisterMessageConsumer
in interface MessagingQueue
consumer
- zu entfernender Consumer.MessagingQueue.unRegisterMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)
public void queueMessage(Message message)
MessagingQueue
queueMessage
in interface MessagingQueue
message
- die zu versendende Nachricht.MessagingQueue.queueMessage(de.willuhn.jameica.messaging.Message)
public void close()
MessagingQueue
close
in interface MessagingQueue
MessagingQueue.close()
public void flush()
MessagingQueue
flush
in interface MessagingQueue
MessagingQueue.flush()
public void sendMessage(Message message)
MessagingQueue
sendMessage
in interface MessagingQueue
message
- die zu versendende Nachricht.MessagingQueue.sendMessage(de.willuhn.jameica.messaging.Message)
public void sendSyncMessage(Message message)
MessagingQueue
sendSyncMessage
in interface MessagingQueue
message
- die zu versendende Nachricht.MessagingQueue.sendSyncMessage(de.willuhn.jameica.messaging.Message)