Class LocalClient

java.lang.Object

io.fluxzero.sdk.configuration.client.AbstractClient

io.fluxzero.sdk.configuration.client.LocalClient

All Implemented Interfaces:

Namespaced<Client>, Client

public class LocalClient
extends AbstractClient

An in-memory Client implementation used for local development, testing, or isolated environments where no connection to the Fluxzero Runtime is required.

This client simulates all major subsystems — including event storage, scheduling, key-value access, and document search — using in-memory data structures with optional message expiration. It is ideal for use cases such as:

• Unit testing message handlers
• Running local development instances without Fluxzero Runtime dependencies
• Offline simulations and demos

Configuration

The default expiration time for messages and scheduled tasks is 2 minutes, but a custom duration can be specified:

LocalClient client = LocalClient.newInstance(Duration.ofMinutes(5));

Features

• Simulates gateway clients for all MessageTypes
• Provides in-memory implementations of event store, scheduling, key-value, and search clients
• Uses the FLUXZERO_TASK_ID environment property or the JVM process name as the client ID
• Reads FLUXZERO_APPLICATION_NAME and FLUXZERO_APPLICATION_ID from environment or system properties

Usage

Typical usage involves passing this client into the FluxzeroBuilder:

Fluxzero fluxzero = DefaultFluxzero.builder().build(LocalClient.newInstance());

Field Summary

Fields inherited from class AbstractClient

shutdownTasks

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LocalClient(Duration messageExpiration)
protected	LocalClient(Duration messageExpiration, String namespace, LocalClient defaultClient)

Method Summary

Modifier and Type	Method	Description
String	applicationId()	Returns the application ID under which this client instance is registered.
protected EventStoreClient	createEventStoreClient()	Subclasses must implement this method to return a EventStoreClient.
protected GatewayClient	createGatewayClient(MessageType messageType, String topic)	Subclasses must implement this method to return a GatewayClient for the given message type and topic.
protected KeyValueClient	createKeyValueClient()	Subclasses must implement this method to return a KeyValueClient.
protected SchedulingClient	createSchedulingClient()	Subclasses must implement this method to return a SchedulingClient.
protected InMemorySearchStore	createSearchClient()	Subclasses must implement this method to return a SearchClient.
protected TrackingClient	createTrackingClient(MessageType messageType, String topic)	Subclasses must implement this method to return a TrackingClient for the given message type and topic.
Client	forNamespace(String namespace)	Creates and returns the resource scoped to the specified namespace.
String	name()	Returns the name of this client as defined in its configuration.
static LocalClient	newInstance()
static LocalClient	newInstance(Duration messageExpiration)

Methods inherited from class AbstractClient

beforeShutdown, getGatewayClient, getTrackingClient, monitorDispatch, shutDown

Methods inherited from class Object

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

Methods inherited from interface Client

getEventStoreClient, getGatewayClient, getKeyValueClient, getSchedulingClient, getSearchClient, getTrackingClient, id, namespace, unwrap

Methods inherited from interface Namespaced

forDefaultNamespace

Constructor Details

LocalClient

protected LocalClient(Duration messageExpiration)

LocalClient

protected LocalClient(Duration messageExpiration,
 String namespace,
 LocalClient defaultClient)

Method Details

newInstance

public static LocalClient newInstance()

newInstance

public static LocalClient newInstance(Duration messageExpiration)

name

public String name()

Description copied from interface: Client

Returns the name of this client as defined in its configuration.

applicationId

public String applicationId()

Description copied from interface: Client

Returns the application ID under which this client instance is registered.

forNamespace

public Client forNamespace(String namespace)

Description copied from interface: Namespaced

Creates and returns the resource scoped to the specified namespace.

Parameters:

namespace - the namespace to which the returned resource is scoped

Returns:

the resource associated with the specified namespace

createGatewayClient

protected GatewayClient createGatewayClient(MessageType messageType,
 String topic)

Description copied from class: AbstractClient

Subclasses must implement this method to return a GatewayClient for the given message type and topic.

Specified by:

createGatewayClient in class AbstractClient

createTrackingClient

protected TrackingClient createTrackingClient(MessageType messageType,
 String topic)

Description copied from class: AbstractClient

Subclasses must implement this method to return a TrackingClient for the given message type and topic.

Specified by:

createTrackingClient in class AbstractClient

createEventStoreClient

protected EventStoreClient createEventStoreClient()

Description copied from class: AbstractClient

Subclasses must implement this method to return a EventStoreClient.

Specified by:

createEventStoreClient in class AbstractClient

createSchedulingClient

protected SchedulingClient createSchedulingClient()

Description copied from class: AbstractClient

Subclasses must implement this method to return a SchedulingClient.

Specified by:

createSchedulingClient in class AbstractClient

createKeyValueClient

protected KeyValueClient createKeyValueClient()

Description copied from class: AbstractClient

Subclasses must implement this method to return a KeyValueClient.

Specified by:

createKeyValueClient in class AbstractClient

createSearchClient

protected InMemorySearchStore createSearchClient()

Description copied from class: AbstractClient

Subclasses must implement this method to return a SearchClient.

Specified by:

createSearchClient in class AbstractClient