Package dev.getelements.elements.test

Class JeroMQEmbeddedInstanceContainer

java.lang.Object

dev.getelements.elements.test.JeroMQEmbeddedInstanceContainer

All Implemented Interfaces:

EmbeddedInstanceContainer, AutoCloseable

Direct Known Subclasses:

JeroMQEmbeddedClientInstanceContainer, JeroMQEmbeddedWorkerInstanceContainer

public class JeroMQEmbeddedInstanceContainer
extends Object
implements EmbeddedInstanceContainer

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAXIMUM_CONNECTIONS
static final int	MINIMUM_CONNECTIONS

Constructor Summary

Constructors

Constructor	Description
JeroMQEmbeddedInstanceContainer()

Method Summary

Modifier and Type	Method	Description
protected void	addConnectAddress(String connectAddress)
protected void	checkNotRunning()
protected void	checkRunning()
JeroMQEmbeddedInstanceContainer	clearConnectAddresses()
void	close()	Closes this EmbeddedWorkerInstanceContainer.
protected void	doClose()
protected void	doStart(org.zeromq.ZContext zContext)
protected com.google.inject.Injector	getInjector()
Instance	getInstance()	Gets the Instance managed by this container.
InstanceId	getInstanceId()	Gets the InstanceId assigned to this container.
Subscription	onClose(Consumer<? super EmbeddedInstanceContainer> consumer)	Registers for a notification when this instance closes.
JeroMQEmbeddedInstanceContainer	start()	Starts this EmbeddedWorkerInstanceContainer.
JeroMQEmbeddedInstanceContainer	withConnectAddress(String address)
JeroMQEmbeddedInstanceContainer	withConnectAddress(String address, String... addresses)
JeroMQEmbeddedInstanceContainer	withInstanceId(InstanceId instanceId)	Specifies the instance id, if not specified then this returns null.
JeroMQEmbeddedInstanceContainer	withInstanceModules(com.google.inject.Module module)
JeroMQEmbeddedInstanceContainer	withInstanceModules(com.google.inject.Module module, com.google.inject.Module... modules)
JeroMQEmbeddedInstanceContainer	withSecurity(JeroMQSecurity jeroMQSecurity)
JeroMQEmbeddedInstanceContainer	withZContext(org.zeromq.ZContext zContext)

Methods inherited from class java.lang.Object

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

Field Details

MINIMUM_CONNECTIONS

public static final int MINIMUM_CONNECTIONS

See Also:

• Constant Field Values

MAXIMUM_CONNECTIONS

public static final int MAXIMUM_CONNECTIONS

See Also:

• Constant Field Values

Constructor Details

JeroMQEmbeddedInstanceContainer

public JeroMQEmbeddedInstanceContainer()

Method Details

withInstanceId

public JeroMQEmbeddedInstanceContainer withInstanceId(InstanceId instanceId)

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

Parameters:

instanceId - the instanceid

Returns:

this instance

withInstanceModules

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

withInstanceModules

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

clearConnectAddresses

public JeroMQEmbeddedInstanceContainer clearConnectAddresses()

withConnectAddress

public JeroMQEmbeddedInstanceContainer withConnectAddress(String address)

withConnectAddress

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

withZContext

public JeroMQEmbeddedInstanceContainer withZContext(org.zeromq.ZContext zContext)

withSecurity

public JeroMQEmbeddedInstanceContainer withSecurity(JeroMQSecurity jeroMQSecurity)

checkRunning

protected void checkRunning()

checkNotRunning

protected void checkNotRunning()

start

public JeroMQEmbeddedInstanceContainer start()

Description copied from interface: EmbeddedInstanceContainer

Starts this EmbeddedWorkerInstanceContainer.

Specified by:

start in interface EmbeddedInstanceContainer

Returns:

this instance

doStart

protected void doStart(org.zeromq.ZContext zContext)

addConnectAddress

protected void addConnectAddress(String connectAddress)

getInjector

protected com.google.inject.Injector getInjector()

onClose

public Subscription onClose(Consumer<? super EmbeddedInstanceContainer> consumer)

Description copied from interface: EmbeddedInstanceContainer

Registers for a notification when this instance closes.

Specified by:

onClose in interface EmbeddedInstanceContainer

Parameters:

consumer - the consumer which receives this event

Returns:

an instance of Subscription

close

public void close()

Description copied from interface: EmbeddedInstanceContainer

Closes this EmbeddedWorkerInstanceContainer.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface EmbeddedInstanceContainer

doClose

protected void doClose()

getInstance

public Instance getInstance()

Description copied from interface: EmbeddedInstanceContainer

Gets the Instance managed by this container.

Specified by:

getInstance in interface EmbeddedInstanceContainer

Returns:

the instance

getInstanceId

public InstanceId getInstanceId()

Description copied from interface: EmbeddedInstanceContainer

Gets the InstanceId assigned to this container.

Specified by:

getInstanceId in interface EmbeddedInstanceContainer

Returns: