Package dev.getelements.elements.rt.routing

Class DefaultRoutingStrategy

java.lang.Object

dev.getelements.elements.rt.routing.DefaultRoutingStrategy

All Implemented Interfaces:

RoutingStrategy

public class DefaultRoutingStrategy
extends Object
implements RoutingStrategy

The default RoutingStrategy which simply selects a RemoteInvoker from the RemoteInvokerRegistry using RemoteInvokerRegistry.getBestRemoteInvoker(ApplicationId) and sends the Invocation there.

Constructor Summary

Constructors

Constructor	Description
DefaultRoutingStrategy()

Method Summary

Modifier and Type	Method	Description
ApplicationId	getApplicationId()
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	setApplicationId(ApplicationId applicationId)
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

DefaultRoutingStrategy

public DefaultRoutingStrategy()

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)

getApplicationId

public ApplicationId getApplicationId()

setApplicationId

@Inject
public void setApplicationId(ApplicationId applicationId)