Package de.kentoj.scrowlib.messaging

Class MessageBroker

java.lang.Object
de.kentoj.scrowlib.messaging.MessageBroker
public class MessageBroker extends Object

  • Field Details

    • dispatcher

      protected final io.nats.client.Dispatcher dispatcher

  • Constructor Details

    • MessageBroker

      public MessageBroker(io.nats.client.Connection nats)

  • Method Details

    • publish

      public void publish(String subject, org.bson.Document document)

    • publish

      public void publish(String subject, com.leakyabstractions.result.api.Result<org.bson.Document,String> result)

    • subscribe

      public void subscribe(String subject, Consumer<org.bson.Document> handler)
      subscribes to a subject, handler may run asynchronously

    • handle

      public void handle(String subject, RequestHandler handler)
      handler may run asynchronously

    • request

      public com.leakyabstractions.result.api.Result<org.bson.Document,String> request(String subject, org.bson.Document document)