public class NamedConcurrentQueue extends java.lang.Object implements MessagingQueue
| Constructor and Description |
|---|
NamedConcurrentQueue(java.lang.String name)
ct.
|
| Modifier and Type | Method and 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)
MessagingQueuesendMessage in interface MessagingQueuemessage - die zu versendende Nachricht.MessagingQueue.sendMessage(de.willuhn.jameica.messaging.Message)public void sendSyncMessage(Message message)
MessagingQueuesendSyncMessage in interface MessagingQueuemessage - die zu versendende Nachricht.MessagingQueue.sendSyncMessage(de.willuhn.jameica.messaging.Message)public void queueMessage(Message message)
MessagingQueuequeueMessage in interface MessagingQueuemessage - die zu versendende Nachricht.MessagingQueue.queueMessage(de.willuhn.jameica.messaging.Message)public int getQueueSize()
MessagingQueuegetQueueSize in interface MessagingQueueMessagingQueue.getQueueSize()public void registerMessageConsumer(MessageConsumer consumer)
MessagingQueueregisterMessageConsumer in interface MessagingQueueconsumer - zu registrierender Consumer.MessagingQueue.registerMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)public void unRegisterMessageConsumer(MessageConsumer consumer)
MessagingQueueunRegisterMessageConsumer in interface MessagingQueueconsumer - zu entfernender Consumer.MessagingQueue.unRegisterMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)public void close()
MessagingQueueclose in interface MessagingQueueMessagingQueue.close()public void flush()
MessagingQueueflush in interface MessagingQueueMessagingQueue.flush()