Module io.fluxzero.sdk

Package io.fluxzero.sdk.configuration

Class DefaultFluxzero

java.lang.Object

io.fluxzero.sdk.configuration.DefaultFluxzero

All Implemented Interfaces:

Fluxzero, AutoCloseable

public class DefaultFluxzero
extends Object
implements Fluxzero

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultFluxzero.Builder

Field Summary

Fields inherited from interface io.fluxzero.sdk.Fluxzero

applicationInstance, instance

Constructor Summary

Constructors

Constructor	Description
DefaultFluxzero()

Method Summary

Modifier and Type	Method	Description
io.fluxzero.common.Registration	beforeShutdown(Runnable task)	Register a task to run before this Fluxzero instance is closed.
static DefaultFluxzero.Builder	builder()
Clock	clock()	Returns the clock used by Fluxzero to generate timestamps.
void	close(boolean silently)	Closes this Fluxzero instance gracefully.
GenericGateway	customGateway(String topic)	Returns the gateway for given custom message topic.
Tracking	tracking(io.fluxzero.common.MessageType messageType)	Returns a client to assist with the tracking of a given message type.
void	withClock(@NonNull Clock clock)	Have Fluxzero use the given Clock when generating timestamps, e.g. when creating a Message.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.fluxzero.sdk.Fluxzero

aggregateRepository, apply, cache, client, close, commandGateway, configuration, correlationDataProvider, documentStore, errorGateway, eventGateway, eventStore, execute, identityProvider, keyValueStore, messageScheduler, metricsGateway, propertySource, queryGateway, registerHandlers, registerHandlers, resultGateway, serializer, snapshotStore, taskScheduler, userProvider, webRequestGateway

Constructor Details

DefaultFluxzero

public DefaultFluxzero()

Method Details

builder

public static DefaultFluxzero.Builder builder()

customGateway

public GenericGateway customGateway(String topic)

Description copied from interface: Fluxzero

Returns the gateway for given custom message topic.

Specified by:

customGateway in interface Fluxzero

tracking

public Tracking tracking(io.fluxzero.common.MessageType messageType)

Description copied from interface: Fluxzero

Returns a client to assist with the tracking of a given message type.

Specified by:

tracking in interface Fluxzero

withClock

public void withClock(@NonNull
 @NonNull Clock clock)

Description copied from interface: Fluxzero

Have Fluxzero use the given Clock when generating timestamps, e.g. when creating a Message.

Specified by:

withClock in interface Fluxzero

clock

public Clock clock()

Description copied from interface: Fluxzero

Returns the clock used by Fluxzero to generate timestamps.

Specified by:

clock in interface Fluxzero

beforeShutdown

public io.fluxzero.common.Registration beforeShutdown(Runnable task)

Description copied from interface: Fluxzero

Register a task to run before this Fluxzero instance is closed.

Specified by:

beforeShutdown in interface Fluxzero

close

public void close(boolean silently)

Description copied from interface: Fluxzero

Closes this Fluxzero instance gracefully. If silently is true, shutdown is done without logging.

Specified by:

close in interface Fluxzero