MessagingFactory
, NamedConcurrentQueue
, NamedQueue
public interface MessagingQueue
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.
|
void sendMessage(Message message)
message
- die zu versendende Nachricht.void sendSyncMessage(Message message)
message
- die zu versendende Nachricht.void queueMessage(Message message)
message
- die zu versendende Nachricht.int getQueueSize()
void registerMessageConsumer(MessageConsumer consumer)
consumer
- zu registrierender Consumer.void unRegisterMessageConsumer(MessageConsumer consumer)
consumer
- zu entfernender Consumer.void close()
void flush()