de.willuhn.jameica.messaging

Class MessageBus

java.lang.Object

de.willuhn.jameica.messaging.MessageBus

public class MessageBus
extends java.lang.Object

Eine Convenience-Klasse zum einfachen Verschicken von Messages an beliebige Channels, ohne extra Message-Objekte erzeugen zu muessen.

Constructor Summary

Constructors

Constructor and Description
MessageBus()

Method Summary

Modifier and Type	Method and Description
static void	queue(java.lang.String queue, java.lang.Object data) Queued eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.
static void	send(java.lang.String queue, java.lang.Object data) Sendet eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.
static void	sendSync(java.lang.String queue, java.lang.Object data) Sendet eine QueryMessage mit den angegebenen Nutzdaten synchron an die Queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageBus

public MessageBus()

Method Detail

send

public static void send(java.lang.String queue,
                        java.lang.Object data)

Sendet eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.

Parameters:

queue - die Queue.

data - die Nutzdaten.

sendSync

public static void sendSync(java.lang.String queue,
                            java.lang.Object data)

Sendet eine QueryMessage mit den angegebenen Nutzdaten synchron an die Queue.

Parameters:

queue - die Queue.

data - die Nutzdaten.

queue

public static void queue(java.lang.String queue,
                         java.lang.Object data)

Queued eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue. Die Message bleibt solange in der Queue, bis ein Consumer vorhanden ist.

Parameters:

queue - die Queue.

data - die Nutzdaten.