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 Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoiddispatch(Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> additionalInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer) Performs the actual dispatch by unpacking theInvocationand collecting the results into the providedConsumer<InvocationResult>.getScope()protected Objectprotected Objectresolve(Class<?> type, Invocation invocation) protected ObjectvoidsetProtocol(String protocol) voidMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface dev.getelements.elements.rt.remote.LocalInvocationDispatcher
dispatch
-
Constructor Details
-
AbstractLocalInvocationDispatcher
public AbstractLocalInvocationDispatcher()
-
-
Method Details
-
dispatch
public void dispatch(Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> additionalInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer) Description copied from interface:LocalInvocationDispatcherPerforms the actual dispatch by unpacking theInvocationand collecting the results into the providedConsumer<InvocationResult>. The suppliedConsumer<InvocationResult>.- Specified by:
dispatchin interfaceLocalInvocationDispatcher- Parameters:
invocation-syncInvocationErrorConsumer-additionalInvocationResultConsumerList-asyncInvocationErrorConsumer-
-
resolve
-
resolve
-
resolve
-
getScope
-
setScope
-
getProtocol
-
setProtocol
-