Class BusRouter

All Implemented Interfaces:
CoreDeployment, CoreHandler, Receiver<Request>
Direct Known Subclasses:

public class BusRouter extends Object implements CoreHandler
Simple handler that routes messages to the event bus and passes eventbus errors back to sender.
  • Constructor Details

    • BusRouter

      public BusRouter()
  • Method Details

    • init

      public void init(CoreContext core)
      Description copied from interface: CoreDeployment
      Init method that is called with the context that the service was deployed from.
      Specified by:
      init in interface CoreDeployment
      core - the core context to use.
    • handle

      public void handle(Request request)
      Description copied from interface: Receiver
      Handles an incoming request without exception handling.
      Specified by:
      handle in interface Receiver<Request>
      request - the request to be handled.
    • send

      protected void send(Request request, String target)
    • onRecipientFailure

      protected void onRecipientFailure(Request request)
    • onNodeNotReachable

      protected void onNodeNotReachable(Request request)
    • onNodeTimeout

      protected void onNodeTimeout(Request request)