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

Class JeroMQAsyncControlClient

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQAsyncControlClient

All Implemented Interfaces:

AsyncControlClient, AutoCloseable

public class JeroMQAsyncControlClient
extends Object
implements AsyncControlClient

Nested Class Summary

Nested classes/interfaces inherited from interface dev.getelements.elements.rt.remote.AsyncControlClient

AsyncControlClient.Factory, AsyncControlClient.Request, AsyncControlClient.Response<T>, AsyncControlClient.ResponseConsumer<T>

Constructor Summary

Constructors

Constructor	Description
JeroMQAsyncControlClient(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> service, String instanceConnectAddress, JeroMQSecurity securityChain)
JeroMQAsyncControlClient(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> service, String instanceConnectAddress, JeroMQSecurity jeroMQSecurity, int minConnections, int maxConnections)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this instance of AsyncControlClient.
AsyncControlClient.Request	closeBinding(NodeId nodeId, AsyncControlClient.ResponseConsumer<Void> responseConsumer)	Issues the command to close a binding.
AsyncControlClient.Request	closeRoutesViaInstance(InstanceId instanceId, String instanceConnectAddress, AsyncControlClient.ResponseConsumer<Void> responseConsumer)	Close the routes via the InstanceId.
AsyncControlClient.Request	getInstanceStatus(AsyncControlClient.ResponseConsumer<InstanceStatus> responseConsumer)	Gets the InstanceId for the remote instance.
AsyncControlClient.Request	openBinding(NodeId nodeId, AsyncControlClient.ResponseConsumer<InstanceConnectionService.InstanceBinding> responseConsumer)	Opens an InstanceConnectionService.InstanceBinding provided the NodeId and returns the InstanceConnectionService.InstanceBinding.
AsyncControlClient.Request	openRouteToNode(NodeId nodeId, String instanceInvokerAddress, AsyncControlClient.ResponseConsumer<String> responseConsumer)	Issues the command to open up a route to the node.

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

withDispatch

Constructor Details

JeroMQAsyncControlClient

public JeroMQAsyncControlClient(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> service,
 String instanceConnectAddress,
 JeroMQSecurity securityChain)

JeroMQAsyncControlClient

public JeroMQAsyncControlClient(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> service,
 String instanceConnectAddress,
 JeroMQSecurity jeroMQSecurity,
 int minConnections,
 int maxConnections)

Method Details

getInstanceStatus

public AsyncControlClient.Request getInstanceStatus(AsyncControlClient.ResponseConsumer<InstanceStatus> responseConsumer)

Description copied from interface: AsyncControlClient

Gets the InstanceId for the remote instance.

Specified by:

getInstanceStatus in interface AsyncControlClient

Parameters:

responseConsumer - the Consumer<AsyncControlClient.Response<InstanceStatus>> to handle the request

Returns:

the AsyncControlClient.Request for the instance status

openRouteToNode

public AsyncControlClient.Request openRouteToNode(NodeId nodeId,
 String instanceInvokerAddress,
 AsyncControlClient.ResponseConsumer<String> responseConsumer)

Description copied from interface: AsyncControlClient

Issues the command to open up a route to the node.

Specified by:

openRouteToNode in interface AsyncControlClient

Parameters:

nodeId - the NodeId

instanceInvokerAddress - the remote instance invoker address

responseConsumer - the Consumer<AsyncControlClient.Response<String>> to handle the request

Returns:

the connect address for the node

closeRoutesViaInstance

public AsyncControlClient.Request closeRoutesViaInstance(InstanceId instanceId,
 String instanceConnectAddress,
 AsyncControlClient.ResponseConsumer<Void> responseConsumer)

Description copied from interface: AsyncControlClient

Close the routes via the InstanceId. If no routes are known, then nothing happens.

Specified by:

closeRoutesViaInstance in interface AsyncControlClient

Parameters:

instanceId - the InstanceId

openBinding

public AsyncControlClient.Request openBinding(NodeId nodeId,
 AsyncControlClient.ResponseConsumer<InstanceConnectionService.InstanceBinding> responseConsumer)

Description copied from interface: AsyncControlClient

Opens an InstanceConnectionService.InstanceBinding provided the NodeId and returns the InstanceConnectionService.InstanceBinding.

Specified by:

openBinding in interface AsyncControlClient

Parameters:

nodeId - the NodeId

Returns:

the InstanceConnectionService.InstanceBinding

closeBinding

public AsyncControlClient.Request closeBinding(NodeId nodeId,
 AsyncControlClient.ResponseConsumer<Void> responseConsumer)

Description copied from interface: AsyncControlClient

Issues the command to close a binding. This will invalidate all InstanceConnectionService.InstanceBindings to that NodeId.

Specified by:

closeBinding in interface AsyncControlClient

Parameters:

nodeId -

close

public void close()

Description copied from interface: AsyncControlClient

Closes this instance of AsyncControlClient. Any pending tasks will be failed with a callback to any pending responses.

Specified by:

close in interface AsyncControlClient

Specified by:

close in interface AutoCloseable