Package de.willuhn.jameica.messaging
Class MessageBus
java.lang.Object
de.willuhn.jameica.messaging.MessageBus
Eine Convenience-Klasse zum einfachen Verschicken von Messages
an beliebige Channels, ohne extra Message-Objekte erzeugen zu muessen.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic void
Queued eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.static void
Sendet eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.static void
Sendet eine QueryMessage mit den angegebenen Nutzdaten synchron an die Queue.
-
Constructor Details
-
MessageBus
public MessageBus()
-
-
Method Details
-
send
Sendet eine QueryMessage mit den angegebenen Nutzdaten asynchron an die Queue.- Parameters:
queue
- die Queue.data
- die Nutzdaten.
-
sendSync
Sendet eine QueryMessage mit den angegebenen Nutzdaten synchron an die Queue.- Parameters:
queue
- die Queue.data
- die Nutzdaten.
-
queue
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.
-