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 TypeMethodDescriptionvoidAbstractLocalInvocationDispatcher.dispatch(Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> additionalInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer) default voidLocalInvocationDispatcher.dispatch(Invocation invocation, ResultHandlerStrategy resultHandlerStrategy) Dispatches using theInvocationandResultHandlerStrategy.voidLocalInvocationDispatcher.dispatch(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>.RemoteInvoker.invoke(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Deprecated.RemoteInvocationDispatcher.invokeAsync(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocationto the remote service and waits for theInvocationResult.RemoteInvoker.invokeAsync(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocationto the remote service and waits for theInvocationResult.RoutingStrategy.invokeAsync(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Invokes the method returning aAsyncOperationfor the value.SimpleRemoteInvocationDispatcher.invokeAsync(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) default VoidRemoteInvocationDispatcher.invokeAsyncV(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) InvokesRemoteInvocationDispatcher.invokeAsyncV(Route, Invocation, List, InvocationErrorConsumer), ignoring the returnedAsyncOperation.default VoidRemoteInvoker.invokeAsyncV(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocationto the remote service and waits for theInvocationResult.default VoidRoutingStrategy.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 theInvocationto the remote service and waits for theInvocationResult.RemoteInvocationDispatcher.invokeFuture(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocationto the remote service and waits for theInvocationResult.RemoteInvoker.invokeFuture(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocationto 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 theInvocationto the remote service and waits for theInvocationResult.default ObjectRemoteInvoker.invokeSync(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer) Sends theInvocationto 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) voidLocalInvocationProcessor.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 ObjectAbstractLocalInvocationDispatcher.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.