Class AbstractLocalInvocationDispatcher

java.lang.Object
dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
All Implemented Interfaces:
LocalInvocationDispatcher
Direct Known Subclasses:
ContextLocalInvocationDispatcher, MasterNodeLocalInvocationDispatcher, ServiceLocatorLocalInvocationDispatcher

public abstract class AbstractLocalInvocationDispatcher extends Object implements LocalInvocationDispatcher
  • Constructor Details

    • AbstractLocalInvocationDispatcher

      public AbstractLocalInvocationDispatcher()
  • Method Details

    • dispatch

      public void dispatch(dev.getelements.elements.rt.remote.Invocation invocation, Consumer<dev.getelements.elements.rt.remote.InvocationResult> syncInvocationResultConsumer, Consumer<dev.getelements.elements.rt.remote.InvocationError> syncInvocationErrorConsumer, List<Consumer<dev.getelements.elements.rt.remote.InvocationResult>> additionalInvocationResultConsumerList, Consumer<dev.getelements.elements.rt.remote.InvocationError> asyncInvocationErrorConsumer)
      Description copied from interface: LocalInvocationDispatcher
      Performs the actual dispatch by unpacking the Invocation and collecting the results into the provided Consumer<dev.getelements.elements.rt.remote.InvocationResult>. The supplied Consumer<dev.getelements.elements.rt.remote.InvocationResult>.
      Specified by:
      dispatch in interface LocalInvocationDispatcher
      Parameters:
      invocation -
      syncInvocationErrorConsumer -
      additionalInvocationResultConsumerList -
      asyncInvocationErrorConsumer -
    • resolve

      protected Object resolve(Class<?> type, dev.getelements.elements.rt.remote.Invocation invocation)
    • resolve

      protected Object resolve(Class<?> type)
    • resolve

      protected Object resolve(Class<?> type, String name)
    • getScope

      public String getScope()
    • setScope

      @Inject public void setScope(@Named("dev.getelements.elements.rt.scope") String scope)
    • getProtocol

      public String getProtocol()
    • setProtocol

      @Inject public void setProtocol(@Named("dev.getelements.elements.rt.protocol") String protocol)