Package dev.getelements.elements.test

Class JeroMQEmbeddedTestService

java.lang.Object

dev.getelements.elements.test.JeroMQEmbeddedTestService

All Implemented Interfaces:

EmbeddedTestService, AutoCloseable

public class JeroMQEmbeddedTestService
extends Object
implements EmbeddedTestService

Embeds a test kit which supplies two Instances. One which runs the client, and one which runs a worker.

Constructor Summary

Constructors

Constructor	Description
JeroMQEmbeddedTestService()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the test service.
Optional<EmbeddedClientInstanceContainer>	getClientOptional()	Gets the client Optional<EmbeddedInstanceContainer>.
Optional<EmbeddedWorkerInstanceContainer>	getWorkerOptional()	Gets the client Optional<EmbeddedWorkerInstanceContainer>.
Subscription	onClose(Consumer<? super EmbeddedTestService> consumer)	Subscribes to an even that is fired when the service is closed.
EmbeddedTestService	start()	Starts the EmbeddedTestService.
JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<JeroMQEmbeddedTestService>	withApplicationNode()	Adds a randomly-assigned
JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<JeroMQEmbeddedTestService>	withApplicationNode(ApplicationId applicationId)	Begins specialized configuration for an application with the specified ApplicationId.
JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<JeroMQEmbeddedTestService>	withApplicationNode(String uniqueName)	Begins specialized configuration for an application with the specified unique name.
JeroMQEmbeddedTestService	withClient()	Configures a client Instance.
JeroMQEmbeddedTestService	withClientModule(com.google.inject.Module module)	Installs the supplied Module to the client Instance.
JeroMQEmbeddedTestService	withDefaultHttpClient()	Installs the default Client to the worker Instance.
JeroMQEmbeddedTestService	withNodeModuleFactory(JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory nodeModuleFactory)	Specifies an JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory to use when creating new Nodes in the worker instance.
JeroMQEmbeddedTestService	withSecurity(JeroMQSecurity jeroMQSecurity)	Specifies an alternative security context.
JeroMQEmbeddedTestService	withUnixFSWorker()	Configures the Worker to use the UnixFS Storage system.
JeroMQEmbeddedTestService	withWorker()	Configures a worker Instance.
JeroMQEmbeddedTestService	withWorkerBindAddress(String workerBindAddress)	Specifies the Worker bind address.
JeroMQEmbeddedTestService	withWorkerModule(com.google.inject.Module module)	Installs the supplied Module to the worker Instance.
JeroMQEmbeddedTestService	withZContext(org.zeromq.ZContext zContext)	Specifies an alternative ZContext.

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

getClient, getClientIocResolver, getIocResolver, getWorker

Constructor Details

JeroMQEmbeddedTestService

public JeroMQEmbeddedTestService()

Method Details

withClient

public JeroMQEmbeddedTestService withClient()

Configures a client Instance.

Returns:

this instance

withWorker

public JeroMQEmbeddedTestService withWorker()

Configures a worker Instance.

Returns:

this instance

withZContext

public JeroMQEmbeddedTestService withZContext(org.zeromq.ZContext zContext)

Specifies an alternative ZContext.

Parameters:

zContext - a zContext

Returns:

withSecurity

public JeroMQEmbeddedTestService withSecurity(JeroMQSecurity jeroMQSecurity)

Specifies an alternative security context.

Parameters:

jeroMQSecurity -

Returns:

withWorkerModule

public JeroMQEmbeddedTestService withWorkerModule(com.google.inject.Module module)

Installs the supplied Module to the worker Instance. If no worker instance was configured, this will implicitly configure a worker instance.

Parameters:

module - the module

Returns:

this instance

withClientModule

public JeroMQEmbeddedTestService withClientModule(com.google.inject.Module module)

Installs the supplied Module to the client Instance. If no client instance was configured, this will implicitly configure a client instance.

Parameters:

module - the module

Returns:

this instance

withDefaultHttpClient

public JeroMQEmbeddedTestService withDefaultHttpClient()

Installs the default Client to the worker Instance. If no worker instance was configured, this will implicitly configure a worker instance.

Returns:

this instance

withWorkerBindAddress

public JeroMQEmbeddedTestService withWorkerBindAddress(String workerBindAddress)

Specifies the Worker bind address.

Parameters:

workerBindAddress - the bind address for the worker

Returns:

this instance

withApplicationNode

public JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<JeroMQEmbeddedTestService> withApplicationNode()

Adds a randomly-assigned

Returns:

withApplicationNode

public JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<JeroMQEmbeddedTestService> withApplicationNode(String uniqueName)

Begins specialized configuration for an application with the specified unique name.

Parameters:

uniqueName - the application unique name

Returns:

a new instance of JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder

withApplicationNode

public JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder<JeroMQEmbeddedTestService> withApplicationNode(ApplicationId applicationId)

Begins specialized configuration for an application with the specified ApplicationId.

Parameters:

applicationId - the an ApplicationId

Returns:

a new instance of JeroMQEmbeddedWorkerInstanceContainer.ApplicationNodeBuilder

withNodeModuleFactory

public JeroMQEmbeddedTestService withNodeModuleFactory(JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory nodeModuleFactory)

Specifies an JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory to use when creating new Nodes in the worker instance.

Parameters:

nodeModuleFactory - the JeroMQEmbeddedWorkerInstanceContainer.NodeModuleFactory

Returns:

the this instance

withUnixFSWorker

public JeroMQEmbeddedTestService withUnixFSWorker()

Configures the Worker to use the UnixFS Storage system.

Returns:

this instance

start

public EmbeddedTestService start()

Description copied from interface: EmbeddedTestService

Starts the EmbeddedTestService.

Specified by:

start in interface EmbeddedTestService

Returns:

getClientOptional

public Optional<EmbeddedClientInstanceContainer> getClientOptional()

Description copied from interface: EmbeddedTestService

Gets the client Optional<EmbeddedInstanceContainer>. Is present only if configured.

Specified by:

getClientOptional in interface EmbeddedTestService

Returns:

the client Optional<EmbeddedInstanceContainer>

getWorkerOptional

public Optional<EmbeddedWorkerInstanceContainer> getWorkerOptional()

Description copied from interface: EmbeddedTestService

Gets the client Optional<EmbeddedWorkerInstanceContainer>. Is present only if configured.

Specified by:

getWorkerOptional in interface EmbeddedTestService

Returns:

the client Optional<EmbeddedWorkerInstanceContainer>

onClose

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

Description copied from interface: EmbeddedTestService

Subscribes to an even that is fired when the service is closed.

Specified by:

onClose in interface EmbeddedTestService

Parameters:

consumer -

Returns:

close

public void close()

Description copied from interface: EmbeddedTestService

Closes the test service.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface EmbeddedTestService