Package de.willuhn.jameica.messaging

Class NamedConcurrentQueue

java.lang.Object

de.willuhn.jameica.messaging.NamedConcurrentQueue

All Implemented Interfaces:

MessagingQueue

public class NamedConcurrentQueue
extends Object
implements MessagingQueue

Implementierung einer benamten Queue, die jedoch mittels ThreadPoolExecutor multi-threaded arbeitet.

Constructor Summary

Constructors

Constructor	Description
NamedConcurrentQueue(String name)	ct.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NamedConcurrentQueue

public NamedConcurrentQueue(String name)

ct.

Parameters:

name - der Name der Queue.

Method Details

sendMessage

public void sendMessage(Message message)

Description copied from interface: MessagingQueue

Sendet eine Nachricht asynchron an alle Nachrichtenverbraucher der Queue.

Specified by:

sendMessage in interface MessagingQueue

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 interface MessagingQueue

Parameters:

message - die zu versendende Nachricht.

See Also:

• MessagingQueue.sendSyncMessage(de.willuhn.jameica.messaging.Message)

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 interface MessagingQueue

Parameters:

message - die zu versendende Nachricht.

See Also:

• MessagingQueue.queueMessage(de.willuhn.jameica.messaging.Message)

getQueueSize

public int getQueueSize()

Description copied from interface: MessagingQueue

Liefert die aktuelle Anzahl noch zuzustellender Nachrichten.

Specified by:

getQueueSize in interface MessagingQueue

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 interface MessagingQueue

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 interface MessagingQueue

Parameters:

consumer - zu entfernender Consumer.

See Also:

• MessagingQueue.unRegisterMessageConsumer(de.willuhn.jameica.messaging.MessageConsumer)

close

public void close()

Description copied from interface: MessagingQueue

Schliesst die Queue und sendet alle noch offenen Nachrichten.

Specified by:

close in interface MessagingQueue

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 interface MessagingQueue

See Also:

• MessagingQueue.flush()