MessagingQueue
public class NamedConcurrentQueue extends java.lang.Object implements MessagingQueue
Constructor | Description |
---|---|
NamedConcurrentQueue(java.lang.String name) |
ct.
|
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.
|
public NamedConcurrentQueue(java.lang.String name)
name
- der Name der Queue.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)
public void queueMessage(Message message)
MessagingQueue
queueMessage
in interface MessagingQueue
message
- die zu versendende Nachricht.MessagingQueue.queueMessage(de.willuhn.jameica.messaging.Message)
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 close()
MessagingQueue
close
in interface MessagingQueue
MessagingQueue.close()
public void flush()
MessagingQueue
flush
in interface MessagingQueue
MessagingQueue.flush()