Package dev.getelements.elements.rt.remote

Class SimpleRemoteInvocationDispatcher

java.lang.Object

dev.getelements.elements.rt.remote.SimpleRemoteInvocationDispatcher

All Implemented Interfaces:

RemoteInvocationDispatcher

public class SimpleRemoteInvocationDispatcher
extends Object
implements RemoteInvocationDispatcher

Constructor Summary

Constructors

Constructor	Description
SimpleRemoteInvocationDispatcher()

Method Summary

Modifier and Type	Method	Description
ServiceLocator	getIocResolver()
RoutingStrategy	getRoutingStrategy(Route route)
AsyncOperation	invokeAsync(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Sends the Invocation to the remote service and waits for the InvocationResult.
Future<Object>	invokeFuture(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Sends the Invocation to the remote service and waits for the InvocationResult.
Object	invokeSync(Route route, Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Sends the Invocation to the remote service and waits for the InvocationResult.
void	setIocResolver(ServiceLocator serviceLocator)

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.RemoteInvocationDispatcher

invokeAsyncV, start, stop

Constructor Details

SimpleRemoteInvocationDispatcher

public SimpleRemoteInvocationDispatcher()

Method Details

invokeFuture

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

Description copied from interface: RemoteInvocationDispatcher

Sends the Invocation to the remote service and waits for the InvocationResult. The supplied Consumer<InvocationError> will relay all encountered errors. Typically this is used with the Dispatch.Type.FUTURE

Specified by:

invokeFuture in interface RemoteInvocationDispatcher

Parameters:

route - the Route through which to send the Invocation

invocation - the outgoing Invocation

asyncInvocationResultConsumerList - a List<Consumer<InvocationResult>> to capture all async results

asyncInvocationErrorConsumer - a Consumer<InvocationError> to receive async errors

Returns:

a Future<Object> which returns the result of the remote invocation

invokeAsync

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

Description copied from interface: RemoteInvocationDispatcher

Sends the Invocation to the remote service and waits for the InvocationResult. The supplied Consumer<InvocationError> will relay all encountered errors. Typically this is used with the Dispatch.Type.ASYNCHRONOUS. This returns the generic Void type to clarify the intention of the method that the underlying Future is discarded, but since is is intended to be used with reflections code, this allows for the method to be easily adapted as such.

Specified by:

invokeAsync in interface RemoteInvocationDispatcher

Parameters:

route - the Route through which to send the Invocation

invocation - the outgoing Invocation

asyncInvocationResultConsumerList - a List<Consumer<InvocationResult>> to capture all async results

asyncInvocationErrorConsumer - a Consumer<InvocationError> to receive async errors

Returns:

a null Void, for the sake of clarity

invokeSync

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

Description copied from interface: RemoteInvocationDispatcher

Sends the Invocation to the remote service and waits for the InvocationResult. The supplied Consumer<InvocationError> will relay all encountered errors. Typically this is used with the Dispatch.Type.SYNCHRONOUS The default implementation of this method simply uses the Future<Object> returned by the method defined by RemoteInvocationDispatcher.invokeFuture(Route, Invocation, List, InvocationErrorConsumer) and blocks on Future.get(). However, the underlying implementation should override this method to implement a more efficient means of blocking, such as actually blocking on the underlying network socket.

Specified by:

invokeSync in interface RemoteInvocationDispatcher

Parameters:

route - the Route through which to send the Invocation

invocation - the outgoing Invocation

asyncInvocationResultConsumerList - a List<Consumer<InvocationResult>> to capture all async results

asyncInvocationErrorConsumer - a Consumer<InvocationError> to receive async errors

Returns:

the result of the remote Invocation

Throws:

Exception

getRoutingStrategy

public RoutingStrategy getRoutingStrategy(Route route)

getIocResolver

public ServiceLocator getIocResolver()

setIocResolver

@Inject
public void setIocResolver(ServiceLocator serviceLocator)