Package dev.getelements.elements.rt.routing

Class SameNodeIdRoutingStrategy

java.lang.Object

dev.getelements.elements.rt.routing.SameNodeIdRoutingStrategy

All Implemented Interfaces:

RoutingStrategy

public class SameNodeIdRoutingStrategy
extends Object
implements RoutingStrategy

A RoutingStrategy which ensures that accepts all address components are instances of HasNodeId and that all NodeId instances point to the same place. Instances of HasNodeId which do not specify the NodeId will be ignored and the call dispatched to the specific NodeId that it determines or an exception will be thrown otherwise. If no NodeIds can be determined from the address, then an exception is thrown. However, this will ensure that the call will be routed to a specific node with the determined NodeId.

Constructor Summary

Constructors

Constructor	Description
SameNodeIdRoutingStrategy()

Method Summary

Modifier and Type	Method	Description
RemoteInvokerRegistry	getRemoteInvokerRegistry()
AsyncOperation	invokeAsync(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Invokes the method returning a AsyncOperation for the value.
Future<Object>	invokeFuture(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Invokes the method returning a Future<Object> with the result.
Object	invokeSync(List<Object> address, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Invokes the method, blocking until it returns on the remote end.
void	setRemoteInvokerRegistry(RemoteInvokerRegistry remoteInvokerRegistry)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface dev.getelements.elements.rt.remote.RoutingStrategy

invokeAsyncV

Constructor Details

SameNodeIdRoutingStrategy

public SameNodeIdRoutingStrategy()

Method Details

invokeFuture

public Future<Object> invokeFuture(List<Object> address,
 Invocation invocation,
 List<Consumer<InvocationResult>> asyncInvocationResultConsumerList,
 InvocationErrorConsumer asyncInvocationErrorConsumer)

Description copied from interface: RoutingStrategy

Invokes the method returning a Future<Object> with the result. Corresponds to RemoteInvoker.invokeFuture(Invocation, List, InvocationErrorConsumer).

Specified by:

invokeFuture in interface RoutingStrategy

Parameters:

address - the address

invocation - the Invocation

asyncInvocationResultConsumerList - the list of Consumer<InvocationResult> instances

asyncInvocationErrorConsumer - the InvocationErrorConsumer to receive the error of the invocation

Returns:

the Future<Object> to handle the return value

invokeAsync

public AsyncOperation invokeAsync(List<Object> address,
 Invocation invocation,
 List<Consumer<InvocationResult>> asyncInvocationResultConsumerList,
 InvocationErrorConsumer asyncInvocationErrorConsumer)

Description copied from interface: RoutingStrategy

Invokes the method returning a AsyncOperation for the value.

Specified by:

invokeAsync in interface RoutingStrategy

Parameters:

address - the address

invocation - the Invocation

asyncInvocationResultConsumerList - the list of Consumer<InvocationResult> instances

asyncInvocationErrorConsumer - the InvocationErrorConsumer to receive the error of the invocation

Returns:

an instance of AsyncOperation

invokeSync

public Object invokeSync(List<Object> address,
 Invocation invocation,
 List<Consumer<InvocationResult>> asyncInvocationResultConsumerList,
 InvocationErrorConsumer asyncInvocationErrorConsumer)
                  throws Exception

Description copied from interface: RoutingStrategy

Invokes the method, blocking until it returns on the remote end. Corresponds to RemoteInvoker.invokeFuture(Invocation, List, InvocationErrorConsumer).

Specified by:

invokeSync in interface RoutingStrategy

Parameters:

address - the address

invocation - the Invocation

asyncInvocationResultConsumerList - the list of Consumer<InvocationResult> instances

asyncInvocationErrorConsumer - the InvocationErrorConsumer to receive the error of the invocation

Returns:

the return value of the remote invocation

Throws:

Exception

getRemoteInvokerRegistry

public RemoteInvokerRegistry getRemoteInvokerRegistry()

setRemoteInvokerRegistry

@Inject
public void setRemoteInvokerRegistry(RemoteInvokerRegistry remoteInvokerRegistry)