Class MessageBus

java.lang.Object

de.willuhn.jameica.messaging.MessageBus

public class MessageBus
extends Object

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

Constructor Summary

Constructors

Constructor	Description
MessageBus()

Method Summary

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

Methods inherited from class Object

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

Constructor Details

MessageBus

public MessageBus()

Method Details

send

public static void send(String queue,
 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(String queue,
 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(String queue,
 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.