Uses of Class
dev.getelements.elements.rt.remote.Invocation
Packages that use Invocation
Package
Description
-
Uses of Invocation in dev.getelements.elements.rt.jrpc
Methods in dev.getelements.elements.rt.jrpc that return InvocationModifier and TypeMethodDescriptionJsonRpcInvocationService.InvocationResolution.newInvocation()
Gets theInvocation
-
Uses of Invocation in dev.getelements.elements.rt.remote
Methods in dev.getelements.elements.rt.remote with parameters of type InvocationModifier and TypeMethodDescriptionvoid
AbstractLocalInvocationDispatcher.dispatch
(Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> additionalInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer) default void
LocalInvocationDispatcher.dispatch
(Invocation invocation, ResultHandlerStrategy resultHandlerStrategy) Dispatches using theInvocation
andResultHandlerStrategy
.void
LocalInvocationDispatcher.dispatch
(Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> additionalInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer) Performs the actual dispatch by unpacking theInvocation
and collecting the results into the providedConsumer<InvocationResult>
.RemoteInvoker.invoke
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Deprecated.RemoteInvocationDispatcher.invokeAsync
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.RemoteInvoker.invokeAsync
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.RoutingStrategy.invokeAsync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Invokes the method returning aAsyncOperation
for the value.SimpleRemoteInvocationDispatcher.invokeAsync
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) default Void
RemoteInvocationDispatcher.invokeAsyncV
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) InvokesRemoteInvocationDispatcher.invokeAsyncV(Route, Invocation, List, InvocationErrorConsumer)
, ignoring the returnedAsyncOperation
.default Void
RemoteInvoker.invokeAsyncV
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.default Void
RoutingStrategy.invokeAsyncV
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Invokes the method asynchronously returning aVoid
(ie null) for the value.RemoteInvoker.invokeCompletionStage
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.RemoteInvocationDispatcher.invokeFuture
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.RemoteInvoker.invokeFuture
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.RoutingStrategy.invokeFuture
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) SimpleRemoteInvocationDispatcher.invokeFuture
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) RemoteInvocationDispatcher.invokeSync
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.default Object
RemoteInvoker.invokeSync
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocation
to the remote service and waits for theInvocationResult
.RoutingStrategy.invokeSync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Invokes the method, blocking until it returns on the remote end.SimpleRemoteInvocationDispatcher.invokeSync
(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) void
LocalInvocationProcessor.processInvocation
(Object target, Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer) Performs the dispatch to the supplied object.protected Object
AbstractLocalInvocationDispatcher.resolve
(Class<?> type, Invocation invocation) -
Uses of Invocation in dev.getelements.elements.rt.remote.jeromq
Methods in dev.getelements.elements.rt.remote.jeromq with parameters of type InvocationModifier and TypeMethodDescriptionJeroMQRemoteInvoker.invokeAsync
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) JeroMQRemoteInvoker.invokeCompletionStage
(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Constructors in dev.getelements.elements.rt.remote.jeromq with parameters of type InvocationModifierConstructorDescriptionJeroMQRemoteInvocation
(JeroMQAsyncOperation asyncOperation, AsyncConnection<org.zeromq.ZContext, org.zeromq.ZMQ.Socket> connection, Invocation invocation, PayloadReader payloadReader, PayloadWriter payloadWriter, Map<String, String> mdcContext, Consumer<Object> syncResultConsumer, Consumer<Throwable> syncErrorConsumer, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) -
Uses of Invocation in dev.getelements.elements.rt.routing
Methods in dev.getelements.elements.rt.routing with parameters of type InvocationModifier and TypeMethodDescriptionAbstractAggregateRoutingStrategy.invokeAsync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) DefaultRoutingStrategy.invokeAsync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) SameNodeIdRoutingStrategy.invokeAsync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) AbstractAggregateRoutingStrategy.invokeFuture
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) DefaultRoutingStrategy.invokeFuture
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) SameNodeIdRoutingStrategy.invokeFuture
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) AbstractAggregateRoutingStrategy.invokeSync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) DefaultRoutingStrategy.invokeSync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) SameNodeIdRoutingStrategy.invokeSync
(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)
RemoteInvoker.invokeFuture(Invocation, List, InvocationErrorConsumer)
, but was renamed for clarity on the behavior.