Package dev.getelements.elements.test

Class JeroMQEmbeddedWorkerInstanceContainer

java.lang.Object

dev.getelements.elements.test.JeroMQEmbeddedInstanceContainer

dev.getelements.elements.test.JeroMQEmbeddedWorkerInstanceContainer

All Implemented Interfaces:

EmbeddedInstanceContainer, EmbeddedWorkerInstanceContainer, AutoCloseable

public class JeroMQEmbeddedWorkerInstanceContainer
extends JeroMQEmbeddedInstanceContainer
implements EmbeddedWorkerInstanceContainer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<ChainedT>
static interface	JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory	Creates a new Node.

Field Summary

Fields inherited from class dev.getelements.elements.test.JeroMQEmbeddedInstanceContainer

MAXIMUM_CONNECTIONS, MINIMUM_CONNECTIONS

Constructor Summary

Constructors

Constructor	Description
JeroMQEmbeddedWorkerInstanceContainer()

Method Summary

Modifier and Type	Method	Description
JeroMQEmbeddedWorkerInstanceContainer	clearConnectAddresses()
protected void	doClose()
protected void	doStart(org.zeromq.ZContext zContext)
String	getBindAddress()	Gets the worker's bind address.
ServiceLocator	getIocResolver()	Returns the default Worker IoC resolver.
ServiceLocator	getIocResolver(NodeId nodeId)	Gets the ServiceLocator for the Node associated with the supplied NodeId
Worker	getWorker()	Gets the underlying Worker.
<ChainedT> JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<ChainedT>	withApplication(ApplicationId applicationId, Supplier<ChainedT> chainedTSupplier)
JeroMQEmbeddedWorkerInstanceContainer	withBindAddress(String bindAddress)
JeroMQEmbeddedWorkerInstanceContainer	withConnectAddress(String address)
JeroMQEmbeddedWorkerInstanceContainer	withConnectAddress(String address, String... addresses)
JeroMQEmbeddedWorkerInstanceContainer	withDefaultHttpClient()	Enables the default HTTP client for the Worker contained in this container.
JeroMQEmbeddedWorkerInstanceContainer	withInstanceId(InstanceId instanceId)	Specifies the instance id, if not specified then this returns null.
JeroMQEmbeddedWorkerInstanceContainer	withInstanceModules(com.google.inject.Module module)
JeroMQEmbeddedWorkerInstanceContainer	withInstanceModules(com.google.inject.Module module, com.google.inject.Module... modules)
JeroMQEmbeddedWorkerInstanceContainer	withNodeModuleFactory(JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory nodeModuleFactory)
JeroMQEmbeddedWorkerInstanceContainer	withSecurity(JeroMQSecurity jeroMQSecurity)
JeroMQEmbeddedWorkerInstanceContainer	withZContext(org.zeromq.ZContext zContext)

Methods inherited from class dev.getelements.elements.test.JeroMQEmbeddedInstanceContainer

addConnectAddress, checkNotRunning, checkRunning, close, getInjector, getInstance, getInstanceId, onClose, start

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.test.EmbeddedInstanceContainer

close, getInstance, getInstanceId, onClose, start

Methods inherited from interface dev.getelements.elements.test.EmbeddedWorkerInstanceContainer

getApplicationId, getIocResolver, getNodeId

Constructor Details

JeroMQEmbeddedWorkerInstanceContainer

public JeroMQEmbeddedWorkerInstanceContainer()

Method Details

doStart

protected void doStart(org.zeromq.ZContext zContext)

Overrides:

doStart in class JeroMQEmbeddedInstanceContainer

clearConnectAddresses

public JeroMQEmbeddedWorkerInstanceContainer clearConnectAddresses()

Overrides:

clearConnectAddresses in class JeroMQEmbeddedInstanceContainer

withInstanceId

public JeroMQEmbeddedWorkerInstanceContainer withInstanceId(InstanceId instanceId)

Description copied from class: JeroMQEmbeddedInstanceContainer

Specifies the instance id, if not specified then this returns null.

Overrides:

withInstanceId in class JeroMQEmbeddedInstanceContainer

Parameters:

instanceId - the instanceid

Returns:

this instance

withInstanceModules

public JeroMQEmbeddedWorkerInstanceContainer withInstanceModules(com.google.inject.Module module)

Overrides:

withInstanceModules in class JeroMQEmbeddedInstanceContainer

withInstanceModules

public JeroMQEmbeddedWorkerInstanceContainer withInstanceModules(com.google.inject.Module module,
 com.google.inject.Module... modules)

Overrides:

withInstanceModules in class JeroMQEmbeddedInstanceContainer

withConnectAddress

public JeroMQEmbeddedWorkerInstanceContainer withConnectAddress(String address)

Overrides:

withConnectAddress in class JeroMQEmbeddedInstanceContainer

withConnectAddress

public JeroMQEmbeddedWorkerInstanceContainer withConnectAddress(String address,
 String... addresses)

Overrides:

withConnectAddress in class JeroMQEmbeddedInstanceContainer

withZContext

public JeroMQEmbeddedWorkerInstanceContainer withZContext(org.zeromq.ZContext zContext)

Overrides:

withZContext in class JeroMQEmbeddedInstanceContainer

withSecurity

public JeroMQEmbeddedWorkerInstanceContainer withSecurity(JeroMQSecurity jeroMQSecurity)

Overrides:

withSecurity in class JeroMQEmbeddedInstanceContainer

withDefaultHttpClient

public JeroMQEmbeddedWorkerInstanceContainer withDefaultHttpClient()

Description copied from interface: EmbeddedWorkerInstanceContainer

Enables the default HTTP client for the Worker contained in this container. s

Specified by:

withDefaultHttpClient in interface EmbeddedWorkerInstanceContainer

Returns:

this instance

getWorker

public Worker getWorker()

Description copied from interface: EmbeddedWorkerInstanceContainer

Gets the underlying Worker.

Specified by:

getWorker in interface EmbeddedWorkerInstanceContainer

Returns:

the worker

getBindAddress

public String getBindAddress()

Description copied from interface: EmbeddedWorkerInstanceContainer

Gets the worker's bind address.

Specified by:

getBindAddress in interface EmbeddedWorkerInstanceContainer

Returns:

the bind address

withBindAddress

public JeroMQEmbeddedWorkerInstanceContainer withBindAddress(String bindAddress)

withApplication

public <ChainedT>
JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<ChainedT> withApplication(ApplicationId applicationId,
 Supplier<ChainedT> chainedTSupplier)

withNodeModuleFactory

public JeroMQEmbeddedWorkerInstanceContainer withNodeModuleFactory(JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory nodeModuleFactory)

doClose

protected void doClose()

Overrides:

doClose in class JeroMQEmbeddedInstanceContainer

getIocResolver

public ServiceLocator getIocResolver()

Description copied from interface: EmbeddedWorkerInstanceContainer

Returns the default Worker IoC resolver. The definition of the default worker is implementation specific. Typically, this is the fist configured ApplicationId

Specified by:

getIocResolver in interface EmbeddedWorkerInstanceContainer

Returns:

the default worker IoC resolver.

getIocResolver

public ServiceLocator getIocResolver(NodeId nodeId)

Description copied from interface: EmbeddedWorkerInstanceContainer

Gets the ServiceLocator for the Node associated with the supplied NodeId

Specified by:

getIocResolver in interface EmbeddedWorkerInstanceContainer

Parameters:

nodeId -

Returns:

the NodeId