Package io.fluxcapacitor.javaclient.configuration

Class DefaultFluxCapacitor

java.lang.Object

io.fluxcapacitor.javaclient.configuration.DefaultFluxCapacitor

All Implemented Interfaces:

FluxCapacitor, AutoCloseable

public class DefaultFluxCapacitor
extends Object
implements FluxCapacitor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultFluxCapacitor.Builder

Field Summary

Fields inherited from interface io.fluxcapacitor.javaclient.FluxCapacitor

applicationInstance, instance

Constructor Summary

Constructors

Constructor	Description
DefaultFluxCapacitor()

Method Summary

Modifier and Type	Method	Description
Registration	beforeShutdown(Runnable task)	Register a task to run before this Flux Capacitor instance is closed.
static DefaultFluxCapacitor.Builder	builder()
Clock	clock()	Returns the clock used by Flux Capacitor to generate timestamps.
void	close(boolean silently)	Closes this Flux Capacitor instance gracefully.
GenericGateway	customGateway(String topic)	Returns the gateway for given custom message topic.
Tracking	tracking(MessageType messageType)	Returns a client to assist with the tracking of a given message type.
void	withClock(@NonNull Clock clock)	Have Flux Capacitor 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.fluxcapacitor.javaclient.FluxCapacitor

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

DefaultFluxCapacitor

public DefaultFluxCapacitor()

Method Details

builder

public static DefaultFluxCapacitor.Builder builder()

customGateway

public GenericGateway customGateway(String topic)

Description copied from interface: FluxCapacitor

Returns the gateway for given custom message topic.

Specified by:

customGateway in interface FluxCapacitor

tracking

public Tracking tracking(MessageType messageType)

Description copied from interface: FluxCapacitor

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

Specified by:

tracking in interface FluxCapacitor

withClock

public void withClock(@NonNull
 @NonNull Clock clock)

Description copied from interface: FluxCapacitor

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

Specified by:

withClock in interface FluxCapacitor

clock

public Clock clock()

Description copied from interface: FluxCapacitor

Returns the clock used by Flux Capacitor to generate timestamps.

Specified by:

clock in interface FluxCapacitor

beforeShutdown

public Registration beforeShutdown(Runnable task)

Description copied from interface: FluxCapacitor

Register a task to run before this Flux Capacitor instance is closed.

Specified by:

beforeShutdown in interface FluxCapacitor

close

public void close(boolean silently)

Description copied from interface: FluxCapacitor

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

Specified by:

close in interface FluxCapacitor