Package dev.getelements.elements.rt.remote.jeromq

Class JeroMQRemoteInvoker

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQRemoteInvoker

All Implemented Interfaces:

RemoteInvoker

public class JeroMQRemoteInvoker
extends Object
implements RemoteInvoker

Field Summary

Fields inherited from interface dev.getelements.elements.rt.remote.RemoteInvoker

DEFAULT_TIMEOUT, DEFAULT_TIMEOUT_UNITS, REMOTE_INVOKER_MAX_CONNECTIONS, REMOTE_INVOKER_MIN_CONNECTIONS

Constructor Summary

Constructors

Constructor	Description
JeroMQRemoteInvoker()

Method Summary

Modifier and Type	Method	Description
AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>	getAsyncConnectionService()
String	getConnectAddress()	Gets the connection address for this RemoteInvoker.
int	getMaxConnections()
int	getMinConnections()
PayloadReader	getPayloadReader()
PayloadWriter	getPayloadWriter()
AsyncOperation	invokeAsync(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Sends the Invocation to the remote service and waits for the InvocationResult.
CompletionStage<Object>	invokeCompletionStage(Invocation invocation, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)	Sends the Invocation to the remote service and waits for the InvocationResult.
void	setAsyncConnectionService(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> asyncConnectionService)
void	setMaxConnections(int maxConnections)
void	setMinConnections(int minConnections)
void	setPayloadReader(PayloadReader payloadReader)
void	setPayloadWriter(PayloadWriter payloadWriter)
void	start(String connectAddress, long timeout, TimeUnit timeoutTimeUnit)	Starts up thin is complete.
void	stop()	Stops this RemoteInvoker.
String	toString()

Methods inherited from class java.lang.Object

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

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

invoke, invokeAsyncV, invokeFuture, invokeSync, start

Constructor Details

JeroMQRemoteInvoker

public JeroMQRemoteInvoker()

Method Details

getConnectAddress

public String getConnectAddress()

Description copied from interface: RemoteInvoker

Gets the connection address for this RemoteInvoker. This should be the last value passed to RemoteInvoker.start(String) or RemoteInvoker.start(String, long, TimeUnit).

Specified by:

getConnectAddress in interface RemoteInvoker

Returns:

the connect address

start

public void start(String connectAddress,
 long timeout,
 TimeUnit timeoutTimeUnit)

Description copied from interface: RemoteInvoker

Starts up thin is complete. The default implementation of this method does nothing in case no setup is necessary.

Specified by:

start in interface RemoteInvoker

stop

public void stop()

Description copied from interface: RemoteInvoker

Stops this RemoteInvoker. This method must gracefully shut down all connections and stop any worker threads. THe default implementation of this method does nothing in case no shutdown is necessary.

Specified by:

stop in interface RemoteInvoker

invokeAsync

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

Description copied from interface: RemoteInvoker

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 RemoteInvoker

Parameters:

invocation - the outgoing Invocation

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

asyncInvocationErrorConsumer - a Consumer<InvocationError> to receive async errors

Returns:

an instance of AsyncOperation

invokeCompletionStage

public CompletionStage<Object> invokeCompletionStage(Invocation invocation,
 List<Consumer<InvocationResult>> asyncInvocationResultConsumerList,
 InvocationErrorConsumer asyncInvocationErrorConsumer)

Description copied from interface: RemoteInvoker

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:

invokeCompletionStage in interface RemoteInvoker

Parameters:

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

getPayloadReader

public PayloadReader getPayloadReader()

setPayloadReader

@Inject
public void setPayloadReader(PayloadReader payloadReader)

getPayloadWriter

public PayloadWriter getPayloadWriter()

setPayloadWriter

@Inject
public void setPayloadWriter(PayloadWriter payloadWriter)

getAsyncConnectionService

public AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> getAsyncConnectionService()

setAsyncConnectionService

@Inject
public void setAsyncConnectionService(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> asyncConnectionService)

getMinConnections

public int getMinConnections()

setMinConnections

@Inject
public void setMinConnections(@Named("dev.getelements.elements.rt.remote.RemoteInvoker.minConnections")
 int minConnections)

getMaxConnections

public int getMaxConnections()

setMaxConnections

@Inject
public void setMaxConnections(@Named("dev.getelements.elements.rt.remote.RemoteInvoker.maxConnections")
 int maxConnections)

toString

public String toString()

Overrides:

toString in class Object