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

Class JeroMQInstanceConnectionService

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQInstanceConnectionService

All Implemented Interfaces:

InstanceConnectionService

public class JeroMQInstanceConnectionService
extends Object
implements InstanceConnectionService

Nested Class Summary

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

InstanceConnectionService.InstanceBinding, InstanceConnectionService.InstanceConnection

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JEROMQ_CLUSTER_BIND_ADDRESS
static final String	JEROMQ_CONNECTION_SERVICE_REFRESH_INTERVAL_SECONDS

Constructor Summary

Constructors

Constructor	Description
JeroMQInstanceConnectionService()

Method Summary

Modifier and Type	Method	Description
List<InstanceConnectionService.InstanceConnection>	getActiveConnections()	Gets a List<InstanceConnectionService.InstanceConnection> representing all active connections.
AsyncControlClient.Factory	getAsyncControlClientFactory()
String	getBindAddress()
InstanceDiscoveryService	getInstanceDiscoveryService()
InstanceId	getInstanceId()	Gets the InstanceId for this InstanceConnectionService.
String	getLocalControlAddress()	Returns the local control address.
long	getRefreshIntervalInSeconds()
jakarta.inject.Provider<RemoteInvoker>	getRemoteInvokerProvider()
JeroMQSecurity	getSecurityChain()
org.zeromq.ZContext	getzContext()
InstanceConnectionService.InstanceBinding	openBinding(NodeId nodeId)	Gets an InstanceConnectionService.InstanceBinding which a node can then use to receive incoming data.
void	refresh()	Forces a refresh from the latest source of data immediately.
void	setAsyncControlClientFactory(AsyncControlClient.Factory asyncControlClientFactory)
void	setBindAddress(String bindAddress)
void	setInstanceDiscoveryService(InstanceDiscoveryService instanceDiscoveryService)
void	setInstanceId(InstanceId instanceId)
void	setRefreshIntervalInSeconds(long refreshIntervalInSeconds)
void	setRemoteInvokerProvider(jakarta.inject.Provider<RemoteInvoker> remoteInvokerProvider)
void	setSecurityChain(JeroMQSecurity securityChain)
void	setzContext(org.zeromq.ZContext zContext)
void	start()	Starts the service.
void	stop()	Stops the service.
Subscription	subscribeToConnect(Consumer<InstanceConnectionService.InstanceConnection> onConnect)	Adds a Consumer<InstanceConnectionService.InstanceConnection> that will be called when a new instance has connected to this InstanceConnectionService.
Subscription	subscribeToDisconnect(Consumer<InstanceConnectionService.InstanceConnection> onDisconnect)	Adds a Consumer<InstanceConnectionService.InstanceConnection> that will be called when a an instance has disconnected from this InstanceConnectionService.

Methods inherited from class java.lang.Object

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

Field Details

JEROMQ_CLUSTER_BIND_ADDRESS

public static final String JEROMQ_CLUSTER_BIND_ADDRESS

See Also:

• Constant Field Values

JEROMQ_CONNECTION_SERVICE_REFRESH_INTERVAL_SECONDS

public static final String JEROMQ_CONNECTION_SERVICE_REFRESH_INTERVAL_SECONDS

See Also:

• Constant Field Values

Constructor Details

JeroMQInstanceConnectionService

public JeroMQInstanceConnectionService()

Method Details

start

public void start()

Description copied from interface: InstanceConnectionService

Starts the service.

Specified by:

start in interface InstanceConnectionService

stop

public void stop()

Description copied from interface: InstanceConnectionService

Stops the service.

Specified by:

stop in interface InstanceConnectionService

refresh

public void refresh()

Description copied from interface: InstanceConnectionService

Forces a refresh from the latest source of data immediately. This will ensure that new InstanceConnectionService.InstanceConnections are added and stale ones removed immediately. All necessary events will be driven as part of this call.

Specified by:

refresh in interface InstanceConnectionService

openBinding

public InstanceConnectionService.InstanceBinding openBinding(NodeId nodeId)

Description copied from interface: InstanceConnectionService

Gets an InstanceConnectionService.InstanceBinding which a node can then use to receive incoming data. If a binding already exists for the supplied NodeId, then an exception will be thrown.

Specified by:

openBinding in interface InstanceConnectionService

Parameters:

nodeId - the NodeId for which the binding will be used.

Returns:

the InstanceConnectionService.InstanceBinding

getActiveConnections

public List<InstanceConnectionService.InstanceConnection> getActiveConnections()

Description copied from interface: InstanceConnectionService

Gets a List<InstanceConnectionService.InstanceConnection> representing all active connections.

Specified by:

getActiveConnections in interface InstanceConnectionService

Returns:

the list of all active InstanceConnectionService.InstanceConnections

subscribeToConnect

public Subscription subscribeToConnect(Consumer<InstanceConnectionService.InstanceConnection> onConnect)

Description copied from interface: InstanceConnectionService

Adds a Consumer<InstanceConnectionService.InstanceConnection> that will be called when a new instance has connected to this InstanceConnectionService.

Specified by:

subscribeToConnect in interface InstanceConnectionService

Parameters:

onConnect - the Consumer<InstanceConnectionService.InstanceConnection>

Returns:

a Subscription that can be cancled later.

subscribeToDisconnect

public Subscription subscribeToDisconnect(Consumer<InstanceConnectionService.InstanceConnection> onDisconnect)

Description copied from interface: InstanceConnectionService

Adds a Consumer<InstanceConnectionService.InstanceConnection> that will be called when a an instance has disconnected from this InstanceConnectionService.

Specified by:

subscribeToDisconnect in interface InstanceConnectionService

Parameters:

onDisconnect - the Consumer<InstanceConnectionService.InstanceConnection>

Returns:

a Subscription that can be cancled later.

getLocalControlAddress

public String getLocalControlAddress()

Description copied from interface: InstanceConnectionService

Returns the local control address. This is an address through which the a control client may be used to control the instance from within the local process space.

Specified by:

getLocalControlAddress in interface InstanceConnectionService

Returns:

the local control address.

getInstanceId

public InstanceId getInstanceId()

Description copied from interface: InstanceConnectionService

Gets the InstanceId for this InstanceConnectionService.

Specified by:

getInstanceId in interface InstanceConnectionService

Returns:

the InstanceId

setInstanceId

@Inject
public void setInstanceId(InstanceId instanceId)

getzContext

public org.zeromq.ZContext getzContext()

setzContext

@Inject
public void setzContext(org.zeromq.ZContext zContext)

getBindAddress

public String getBindAddress()

setBindAddress

@Inject
public void setBindAddress(@Named("dev.getelements.elements.rt.remote.jeromq.bind.addr")
 String bindAddress)

getRemoteInvokerProvider

public jakarta.inject.Provider<RemoteInvoker> getRemoteInvokerProvider()

setRemoteInvokerProvider

@Inject
public void setRemoteInvokerProvider(jakarta.inject.Provider<RemoteInvoker> remoteInvokerProvider)

getRefreshIntervalInSeconds

public long getRefreshIntervalInSeconds()

setRefreshIntervalInSeconds

@Inject
public void setRefreshIntervalInSeconds(@Named("dev.getelements.elements.rt.remote.jeromq.connection.service.refresh.interval.sec")
 long refreshIntervalInSeconds)

getInstanceDiscoveryService

public InstanceDiscoveryService getInstanceDiscoveryService()

setInstanceDiscoveryService

@Inject
public void setInstanceDiscoveryService(InstanceDiscoveryService instanceDiscoveryService)

getAsyncControlClientFactory

public AsyncControlClient.Factory getAsyncControlClientFactory()

setAsyncControlClientFactory

@Inject
public void setAsyncControlClientFactory(AsyncControlClient.Factory asyncControlClientFactory)

getSecurityChain

public JeroMQSecurity getSecurityChain()

setSecurityChain

@Inject
public void setSecurityChain(JeroMQSecurity securityChain)