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 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.