Package de.willuhn.jameica.messaging

Class NamedQueue

java.lang.Object

de.willuhn.jameica.messaging.NamedQueue

All Implemented Interfaces:

MessagingQueue

public final class NamedQueue
extends Object
implements MessagingQueue

Implementierung einer Queue, die einen Namen hat.

Author:

willuhn

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.
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.

Methods inherited from class java.lang.Object

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

Method Details

getName

public String getName()

Liefert den Namen der Queue.

Returns:

Name der Queue.

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)

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)

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()

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)