Package de.willuhn.jameica.messaging
Class MessageBus
- java.lang.Object
-
- de.willuhn.jameica.messaging.MessageBus
-
public class MessageBus extends java.lang.ObjectEine 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
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidqueue(java.lang.String queue, java.lang.Object data)Queued eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.static voidsend(java.lang.String queue, java.lang.Object data)Sendet eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.static voidsendSync(java.lang.String queue, java.lang.Object data)Sendet eine QueryMessage mit den angegebenen Nutzdaten synchron an die Queue.
-
-
-
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.
-
-