Package dev.getelements.elements.rt.remote

Class SimpleInstance

java.lang.Object

dev.getelements.elements.rt.remote.SimpleInstance

All Implemented Interfaces:

Instance, AutoCloseable

Direct Known Subclasses:

SimpleWorkerInstance

public class SimpleInstance
extends Object
implements Instance

Field Summary

Fields

Modifier and Type	Field	Description
protected InstanceId	instanceId

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

EXECUTOR_SERVICE, SCHEDULED_EXECUTOR_SERVICE, THREAD_GROUP

Constructor Summary

Constructors

Constructor	Description
SimpleInstance()

Method Summary

Modifier and Type	Method	Description
void	close()	Attempts to stop the instance.
AsyncConnectionService<?,?>	getAsyncConnectionService()
InstanceConnectionService	getInstanceConnectionService()
InstanceDiscoveryService	getInstanceDiscoveryService()
InstanceId	getInstanceId()	Gets this instances InstanceId
RemoteInvokerRegistry	getRemoteInvokerRegistry()
protected void	postClose(Consumer<Exception> exceptionConsumer)
protected void	postStart(Consumer<Exception> exceptionConsumer)
protected void	preClose(Consumer<Exception> exceptionConsumer)
protected void	preStart(Consumer<Exception> exceptionConsumer)
void	refreshConnections()	Forces a refresh of the underlying connections as necessary.
void	setAsyncConnectionService(AsyncConnectionService<?,?> asyncConnectionService)
void	setInstanceConnectionService(InstanceConnectionService instanceConnectionService)
void	setInstanceDiscoveryService(InstanceDiscoveryService instanceDiscoveryService)
void	setInstanceId(InstanceId instanceId)
void	setRemoteInvokerRegistry(RemoteInvokerRegistry remoteInvokerRegistry)
void	start()	Attempts to start, throwing an instance of MultiException any failures happen during the startup process.

Methods inherited from class java.lang.Object

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

Field Details

instanceId

protected InstanceId instanceId

Constructor Details

SimpleInstance

public SimpleInstance()

Method Details

start

public void start()

Description copied from interface: Instance

Attempts to start, throwing an instance of MultiException any failures happen during the startup process. A subsequent call to Instance.close() should follow to ensure resources are cleaned up.

Specified by:

start in interface Instance

preStart

protected void preStart(Consumer<Exception> exceptionConsumer)

postStart

protected void postStart(Consumer<Exception> exceptionConsumer)

close

public void close()

Description copied from interface: Instance

Attempts to stop the instance.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Instance

preClose

protected void preClose(Consumer<Exception> exceptionConsumer)

postClose

protected void postClose(Consumer<Exception> exceptionConsumer)

refreshConnections

public void refreshConnections()

Description copied from interface: Instance

Forces a refresh of the underlying connections as necessary.

Specified by:

refreshConnections in interface Instance

getInstanceId

public InstanceId getInstanceId()

Description copied from interface: Instance

Gets this instances InstanceId

Specified by:

getInstanceId in interface Instance

Returns:

the InstanceId

setInstanceId

@Inject
public void setInstanceId(InstanceId instanceId)

getRemoteInvokerRegistry

public RemoteInvokerRegistry getRemoteInvokerRegistry()

setRemoteInvokerRegistry

@Inject
public void setRemoteInvokerRegistry(RemoteInvokerRegistry remoteInvokerRegistry)

getInstanceDiscoveryService

public InstanceDiscoveryService getInstanceDiscoveryService()

setInstanceDiscoveryService

@Inject
public void setInstanceDiscoveryService(InstanceDiscoveryService instanceDiscoveryService)

getInstanceConnectionService

public InstanceConnectionService getInstanceConnectionService()

setInstanceConnectionService

@Inject
public void setInstanceConnectionService(InstanceConnectionService instanceConnectionService)

getAsyncConnectionService

public AsyncConnectionService<?,?> getAsyncConnectionService()

setAsyncConnectionService

@Inject
public void setAsyncConnectionService(AsyncConnectionService<?,?> asyncConnectionService)