Package 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 Description MessageBus()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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.
-
-