Interface Fluxzero

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
DefaultFluxzero
public interface Fluxzero extends AutoCloseable
High-level entry point for all interactions with the Fluxzero Runtime.

This interface exposes static convenience methods to publish and track messages, interact with aggregates, schedule tasks, index/search documents, and more. It is designed to reduce boilerplate and promote location transparency in message-driven systems.

Usage Patterns

Most applications will never need to hold or inject a Fluxzero instance directly. Instead, the Java SDK automatically binds the relevant instance to a thread-local scope, allowing access via static methods.

A concrete instance is typically constructed using DefaultFluxzero.

  • Field Details

    • applicationInstance

      static final AtomicReference<Fluxzero> applicationInstance
      Fluxzero instance set by the current application. Used as a fallback when no threadlocal instance was set. This is added as a convenience for applications that never have more than one than Fluxzero instance which will be the case for nearly all applications. On application startup simply fill this application instance.

    • instance

      static final ThreadLocal<Fluxzero> instance
      Thread-local binding of the current Fluxzero instance.

      This is automatically set during message processing to ensure that handlers can invoke commands, queries, or schedule events without explicitly injecting dependencies.

      Example: Inside a @HandleCommand method, you can call Fluxzero.sendCommand(...) and it will automatically use the correct instance, without needing manual wiring.

  • Method Details

    • get

      static Fluxzero get()
      Returns the Fluxzero instance bound to the current thread or else set by the current application. Throws an exception if no instance was registered.

    • getOptionally

      static Optional<Fluxzero> getOptionally()
      Returns the Fluxzero client bound to the current thread or else set by the current application as Optional. Returns an empty Optional if no instance was registered.

    • currentClock

      static Clock currentClock()
      Gets the clock of the current Fluxzero instance (obtained via getOptionally()). If there is no current instance the system's UTC clock is returned.

    • currentTime

      static Instant currentTime()
      Gets the time according to the current Fluxzero clock (obtained via currentClock()). If there is no current Fluxzero instance the system's UTC time is returned.

    • generateId

      static String generateId()
      Generates a functional ID using the current IdentityProvider. This is typically used for application-level entities such as aggregates or user-defined messages.
      Returns:
      a unique, traceable identifier string

    • generateId

      static <T extends Id<?>> T generateId(Class<T> idClass)
      Generates a strongly typed ID of given idClass using the current IdentityProvider.
      Returns:
      a unique, traceable typed identifier

    • currentIdentityProvider

      static IdentityProvider currentIdentityProvider()
      Fetches the configured identity provider used for both functional and technical IDs. The default is a UuidFactory that generates UUIDs.

      If there is no current Fluxzero instance, a new UUID factory is generated.

    • currentCorrelationData

      static Map<String,String> currentCorrelationData()
      Gets the current correlation data, which by default depends on the current Client, Tracker and DeserializingMessage

    • publishEvent

      static void publishEvent(Object event)
      Publishes the given application event. The event may be an instance of a Message in which case it will be published as is. Otherwise the event is published using the passed value as payload without additional metadata.

      Note: These events are not persisted for event sourcing. To publish domain events as part of an aggregate lifecycle, apply the events using Entity.apply(Object...) after loading an entity.

      See Also:

    • publishEvent

      static void publishEvent(Object payload, Metadata metadata)
      Publishes an event with given payload and metadata.

      Note: These events are not persisted for event sourcing. To publish domain events as part of an aggregate lifecycle, apply the events using Entity.apply(Object...) after loading an entity.

      See Also:

    • publishEvents

      static void publishEvents(Object... events)
      Publishes given application events. The events may be instances of Message in which case they will be published as is. Otherwise, the events are published using the passed value as payload without additional metadata.

      Note: These events are not persisted for event sourcing. To publish domain events as part of an aggregate lifecycle, apply the events using Entity.apply(Object...) after loading an entity.

      See Also:

    • sendAndForgetCommand

      static void sendAndForgetCommand(Object command)
      Sends the given command and doesn't wait for a result. The command may be an instance of a Message in which case it will be sent as is. Otherwise the command is published using the passed value as payload without additional metadata.
      See Also:

    • sendAndForgetCommands

      static void sendAndForgetCommands(Object... commands)
      Sends the given commands and doesn't wait for results. Commands may be an instance of a Message in which case it will be sent as is. Otherwise, the commands are published using the passed value as payload without additional metadata.
      See Also:

    • sendAndForgetCommand

      static void sendAndForgetCommand(Object payload, Metadata metadata)
      Sends a command with given payload and metadata and don't wait for a result.
      See Also:

    • sendAndForgetCommand

      static void sendAndForgetCommand(Object payload, Metadata metadata, Guarantee guarantee)
      Sends a command with given payload and metadata and don't wait for a result. With a guarantee the method will wait for the command itself to be sent or stored.
      See Also:

    • sendCommand

      static <R> CompletableFuture<R> sendCommand(Object command)
      Sends the given command and returns a future that will be completed with the command's result. The command may be an instance of a Message in which case it will be sent as is. Otherwise the command is published using the passed value as payload without additional metadata.

    • sendCommand

      static <R> CompletableFuture<R> sendCommand(Request<R> command)
      Sends the given command and returns a future that will be completed with the command's result. The command may be an instance of a Message in which case it will be sent as is. Otherwise the command is published using the passed value as payload without additional metadata.

      The return type is determined by the given command.

    • sendCommands

      static <R> List<CompletableFuture<R>> sendCommands(Object... commands)
      Sends the given commands and returns a list of futures that will be completed with the commands' results. The commands may be instances of a Message in which case they will be sent as is. Otherwise, the commands are published using the passed values as payload without additional metadata.

    • sendCommand

      static <R> CompletableFuture<R> sendCommand(Object payload, Metadata metadata)
      Sends a command with given payload and metadata and returns a future that will be completed with the command's result.

    • sendCommand

      static <R> CompletableFuture<R> sendCommand(Request<R> payload, Metadata metadata)
      Sends a command with given payload and metadata and returns a future that will be completed with the command's result.

      The return type is determined by the given command.

    • sendCommandAndWait

      static <R> R sendCommandAndWait(Object command)
      Sends the given command and returns the command's result. The command may be an instance of a Message in which case it will be sent as is. Otherwise, the command is published using the passed value as payload without additional metadata.

    • sendCommandAndWait

      static <R> R sendCommandAndWait(Request<R> command)
      Sends the given command and returns the command's result. The command may be an instance of a Message in which case it will be sent as is. Otherwise, the command is published using the passed value as payload without additional metadata.

      The return type is determined by the given command.

    • sendCommandAndWait

      static <R> R sendCommandAndWait(Object payload, Metadata metadata)
      Sends a command with given payload and metadata and returns a future that will be completed with the command's result.

    • sendCommandAndWait

      static <R> R sendCommandAndWait(Request<R> payload, Metadata metadata)
      Sends a command with given payload and metadata and returns a future that will be completed with the command's result.

      The return type is determined by the given command.

    • query

      static <R> CompletableFuture<R> query(Object query)
      Sends the given query and returns a future that will be completed with the query's result. The query may be an instance of a Message in which case it will be sent as is. Otherwise, the query is published using the passed value as payload without additional metadata.

    • query

      static <R> CompletableFuture<R> query(Request<R> query)
      Sends the given query and returns a future that will be completed with the query's result. The query may be an instance of a Message in which case it will be sent as is. Otherwise, the query is published using the passed value as payload without additional metadata.

      The return type is determined by the given query.

    • query

      static <R> CompletableFuture<R> query(Object payload, Metadata metadata)
      Sends a query with given payload and metadata and returns a future that will be completed with the query's result.

    • query

      static <R> CompletableFuture<R> query(Request<R> payload, Metadata metadata)
      Sends a query with given payload and metadata and returns a future that will be completed with the query's result.

      The return type is determined by the given query.

    • queryAndWait

      static <R> R queryAndWait(Object query)
      Sends the given query and returns the query's result. The query may be an instance of a Message in which case it will be sent as is. Otherwise, the query is published using the passed value as payload without additional metadata.

    • queryAndWait

      static <R> R queryAndWait(Request<R> query)
      Sends the given query and returns the query's result. The query may be an instance of a Message in which case it will be sent as is. Otherwise, the query is published using the passed value as payload without additional metadata.

      The return type is determined by the given query.

    • queryAndWait

      static <R> R queryAndWait(Object payload, Metadata metadata)
      Sends a query with given payload and metadata and returns the query's result.

    • queryAndWait

      static <R> R queryAndWait(Request<R> payload, Metadata metadata)
      Sends a query with given payload and metadata and returns the query's result.

      The return type is determined by the given query.

    • schedulePeriodic

      static String schedulePeriodic(Object schedule)
      Starts a new periodic schedule, returning the schedule's id. The schedule parameter may be an instance of a Message or the schedule payload. If the payload is not annotated with Periodic an IllegalArgumentException is thrown.
      See Also:

    • schedulePeriodic

      static void schedulePeriodic(Object schedule, Object scheduleId)
      Starts a new periodic schedule using given schedule id. The schedule parameter may be an instance of a Message or the schedule payload. If the payload is not annotated with Periodic an IllegalArgumentException is thrown.
      See Also:

    • schedule

      static String schedule(Object schedule, Instant deadline)
      Schedules a message for the given timestamp, returning the schedule's id. The schedule parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the schedule is published using the passed value as payload without additional metadata.

    • schedule

      static void schedule(Object schedule, Object scheduleId, Instant deadline)
      Schedules a message with given scheduleId for the given timestamp. The schedule parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the schedule is published using the passed value as payload without additional metadata.

    • schedule

      static String schedule(Object schedule, Duration delay)
      Schedules a message after the given delay, returning the schedule's id. The schedule parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the schedule is published using the passed value as payload without additional metadata.

    • schedule

      static void schedule(Object schedule, Object scheduleId, Duration delay)
      Schedules a message with given scheduleId after given delay. The schedule parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the schedule is published using the passed value as payload without additional metadata.

    • schedule

      static void schedule(Schedule schedule)
      Schedule a message object (of type Schedule) for execution, using the Guarantee.SENT guarantee.
      Parameters:
      schedule - the message to schedule

    • schedule

      static void schedule(Schedule schedule, boolean ifAbsent)
      Schedule a message object (of type Schedule) for execution, using the Guarantee.SENT guarantee.
      Parameters:
      schedule - the message to schedule

    • scheduleCommand

      static String scheduleCommand(Object command, Instant deadline)
      Schedules a command for the given timestamp, returning the command schedule's id. The command parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the command is scheduled using the passed value as payload without additional metadata.

    • scheduleCommand

      static void scheduleCommand(Object command, Object scheduleId, Instant deadline)
      Schedules a command with given scheduleId for the given timestamp. The command parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the command is published using the passed value as payload without additional metadata.

    • scheduleCommand

      static String scheduleCommand(Object command, Duration delay)
      Schedules a command after given delay, returning the command schedule's id. The command parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the command is scheduled using the passed value as payload without additional metadata.

    • scheduleCommand

      static void scheduleCommand(Object command, Object scheduleId, Duration delay)
      Schedules a command with given scheduleId after given delay. The command parameter may be an instance of a Message in which case it will be scheduled as is. Otherwise, the command is published using the passed value as payload without additional metadata.

    • scheduleCommand

      static void scheduleCommand(Schedule message)
      Schedule a command using the given scheduling settings, using the Guarantee.SENT guarantee.

    • scheduleCommand

      static void scheduleCommand(Schedule message, boolean ifAbsent)
      Schedule a command using the given scheduling settings if no other with same ID exists, using the Guarantee.SENT guarantee.

    • cancelSchedule

      static void cancelSchedule(Object scheduleId)
      Cancels the schedule with given scheduleId.

    • sendWebRequest

      static CompletableFuture<WebResponse> sendWebRequest(WebRequest request)
      Sends the given web request using default request settings and returns a future that completes with the response.

      The request must have an absolute URL to be forwarded by the Fluxzero proxy.

    • sendWebRequest

      static CompletableFuture<WebResponse> sendWebRequest(WebRequest request, WebRequestSettings settings)
      Sends the given web request using the given request settings and returns a future that completes with the response.

      The request must have an absolute URL to be forwarded by the Fluxzero proxy.

    • sendWebRequestAndWait

      static WebResponse sendWebRequestAndWait(WebRequest request)
      Sends the given web request using default request settings and waits for the response synchronously.

      This method blocks the calling thread until the request is completed or times out.

      The request must have an absolute URL to be forwarded by the Fluxzero proxy.

    • sendWebRequestAndWait

      static WebResponse sendWebRequestAndWait(WebRequest request, WebRequestSettings settings)
      Sends the given web request using given request settings and waits for the response synchronously.

      This method blocks the calling thread until the request is completed or times out.

      The request must have an absolute URL to be forwarded by the Fluxzero proxy.

    • publishMetrics

      static void publishMetrics(Object metrics)
      Publishes a metrics event. The parameter may be an instance of a Message in which case it will be sent as is. Otherwise the metrics event is published using the passed value as payload without additional metadata.

      Metrics events can be published in any form to log custom performance metrics about an application.

    • publishMetrics

      static void publishMetrics(Object payload, Metadata metadata)
      Publishes a metrics event with given payload and metadata. Metrics events can be published in any form to log custom performance metrics about an application.

    • loadAggregate

      static <T> Entity<T> loadAggregate(Id<T> aggregateId)
      Loads the aggregate root of type <T> with given aggregateId.

      If the aggregate is loaded while handling an event of the aggregate, the returned Aggregate will automatically be played back to the event currently being handled. Otherwise, the most recent state of the aggregate is loaded.

      See Also:

    • loadAggregate

      static <T> Entity<T> loadAggregate(Object aggregateId)
      Loads the aggregate root with the given aggregateId. If the aggregate exists, it will be loaded and returned with its respective type, if not, an empty Entity of type Object will be returned.

      If the aggregate is loaded while handling an event of the aggregate, the returned Aggregate will automatically be played back to the event currently being handled. Otherwise, the most recent state of the aggregate is loaded.

      See Also:

    • loadAggregate

      static <T> Entity<T> loadAggregate(Object aggregateId, Class<T> aggregateType)
      Loads the aggregate root of type <T> with given aggregateId.

      If the aggregate is loaded while handling an event of the aggregate, the returned Aggregate will automatically be played back to the event currently being handled. Otherwise, the most recent state of the aggregate is loaded.

      See Also:

    • loadAggregateFor

      static <T> Entity<T> loadAggregateFor(Object entityId, Class<?> defaultType)
      Loads the aggregate root of type <T> that currently contains the entity with given entityId. If no such aggregate exists an empty aggregate root is returned with given defaultType as its type.

      This method can also be used if the entity is the aggregate root (aggregateId is equal to entityId). If the entity is associated with more than one aggregate the behavior of this method is unpredictable, though the default behavior is that any one of the associated aggregates is returned.

      If the aggregate is loaded while handling an event of the aggregate, the returned Aggregate will automatically be played back to the event currently being handled. Otherwise, the most recent state of the aggregate is loaded.

      See Also:

    • loadAggregateFor

      static <T> Entity<T> loadAggregateFor(Object entityId)
      Loads the aggregate root that currently contains the entity with given entityId. If no such aggregate exists an empty aggregate root is returned of type Object. In that case be aware that applying events to create the aggregate may yield an undesired result; to prevent this use loadAggregateFor(Object, Class).

      This method can also be used if the entity is the aggregate root (aggregateId is equal to entityId). If the entity is associated with more than one aggregate the behavior of this method is unpredictable, though the default behavior is that any one of the associated aggregates is returned.

      If the aggregate is loaded while handling an event of the aggregate, the returned Aggregate will automatically be played back to the event currently being handled. Otherwise, the most recent state of the aggregate is loaded.

      See Also:

    • loadEntity

      static <T> Entity<T> loadEntity(Object entityId)
      Loads the entity with given id. If the entity is not associated with any aggregate yet, a new aggregate root is loaded with the entityId as aggregate identifier. In case multiple entities are associated with the given entityId the most recent entity is returned.

      If the entity is loaded while handling an event its aggregate, the returned entity will automatically be played back to the event currently being handled. Otherwise, the most recent state of the entity is loaded.

    • loadEntity

      static <T> Entity<T> loadEntity(Id<T> entityId)
      Loads the entity with given id. If the entity is not associated with any aggregate yet, a new aggregate root is loaded with the entityId as aggregate identifier. In case multiple entities are associated with the given entityId the most recent entity is returned.

      If the entity is loaded while handling an event its aggregate, the returned entity will automatically be played back to the event currently being handled. Otherwise, the most recent state of the entity is loaded.

    • loadEntityValue

      static <T> T loadEntityValue(Object entityId)
      Loads the current entity value for given entity id. Entity may be the aggregate root or any ancestral entity. If no such entity exists or its value is not set null is returned.

      If the entity is loaded while handling an event its aggregate, the returned entity will automatically be played back to the event currently being handled. Otherwise, the most recent state of the entity is loaded.

    • loadEntityValue

      static <T> T loadEntityValue(Id<T> entityId)
      Loads the current entity value for given entity id. Entity may be the aggregate root or any ancestral entity. If no such entity exists or its value is not set null is returned.

      If the entity is loaded while handling an event its aggregate, the returned entity will automatically be played back to the event currently being handled. Otherwise, the most recent state of the entity is loaded.

    • asEntity

      static <T> Entity<T> asEntity(T value)
      Returns an Entity containing given value. The returned entity won't exhibit any side effects when they are updated, i.e. they won't be synced to any repository or give rise to any events. Other than, that they are fully functional.

    • prepareIndex

      static IndexOperation prepareIndex(@NonNull @NonNull Object object)
      Prepare given object for indexing for search. This returns a mutable builder that allows defining an id, collection, etc.

      If the object is annotated with @Searchable the collection name and any timestamp or end path defined there will be used.

      If the object has a property annotated with EntityId, it will be used as the id of the document. Otherwise, a random id will be assigned to the document.

      This method returns once the object is stored.

      See Also:

    • index

      static CompletableFuture<Void> index(Object object)
      Index given object for search.

      If the object is annotated with @Searchable the collection name and any timestamp or end path defined there will be used.

      If the object has a property annotated with EntityId, it will be used as the id of the document. Otherwise, a random id will be assigned to the document.

      This method returns once the object is stored.

      See Also:

    • index

      static CompletableFuture<Void> index(Object object, Object collection)
      Index given object for search.

      If the object has a property annotated with EntityId, it will be used as the id of the document. Otherwise, a random id will be assigned to the document.

      This method returns once the object is stored.

      See Also:

    • index

      static CompletableFuture<Void> index(Object object, Object id, Object collection)
      Index given object for search. This method returns once the object is stored.
      See Also:

    • index

      static CompletableFuture<Void> index(Object object, Object id, Object collection, Instant timestamp)
      Index given object for search. This method returns once the object is stored.
      See Also:

    • index

      static CompletableFuture<Void> index(Object object, Object id, Object collection, Instant begin, Instant end)
      Index given object for search. This method returns once the object is stored.
      See Also:

    • index

      static <T> CompletableFuture<Void> index(Collection<? extends T> objects, Object collection, Function<? super T, String> idFunction, Function<? super T, Instant> timestampFunction, Function<? super T, Instant> endFunction)
      Index given objects for search. Use idFunction to provide the document's required id. Use timestampFunction and endFunction to provide the object's timestamp. If none are supplied the document will not be timestamped.

      This method returns once all objects are stored.

      See Also:

    • search

      static Search search(Object collection)
      Search the given collection for documents. Usually collection is the String name of the collection. However, it is also possible to call it with a Collection containing one or multiple collection names.

      If collection is of type Class it is expected that the class is annotated with Searchable. It will then use the collection configured there.

      For all other inputs, the collection name will be obtained by calling Object.toString() on the input.

      Example usage: Fluxzero.search("myCollection").query("foo !bar").fetch(100);

    • search

      static Search search(Object collection, Object... additionalCollections)
      Search the given collections for documents.

      If collection is of type Class it is expected that the class is annotated with * Searchable. It will then use the collection configured there. For all other inputs, the collection name will be obtained by calling Object.toString() on the input.

      Example usage: Fluxzero.search("myCollection", "myOtherCollection).query("foo !bar").fetch(100);

    • search

      static Search search(SearchQuery.Builder queryBuilder)
      Search documents using given reusable query builder.

      Example usage: Fluxzero.search(SearchQuery.builder().search("myCollection").query("foo !bar")).fetch(100);

    • hasDocument

      static boolean hasDocument(Id<?> id)
      Checks whether a document exists for the given identifier and its associated type. The type is used to determine the document collection.

    • hasDocument

      static boolean hasDocument(Object id, Object collection)
      Checks if a document exists in the specified collection.

    • getDocument

      static <T> Optional<T> getDocument(Id<T> id)
      Fetches a document by id using the associated type to determine the collection. The result is deserialized into the stored type.

    • getDocument

      static <T> Optional<T> getDocument(Object id, Object collection)
      Gets the document with given id in given collection, returning the value in the type that it was stored.

    • getDocument

      static <T> Optional<T> getDocument(Object id, Class<T> collection)
      Gets the document with given id in given collection type, returning the value.

    • getDocument

      static <T> Optional<T> getDocument(Object id, Object collection, Class<T> type)
      Gets the document with given id in given collection, converting the matching document to a value with given type.

    • getDocuments

      static <T> Collection<T> getDocuments(Collection<?> ids, Object collection)
      Gets a collection of documents by their IDs from the given collection and deserializes them into the stored type.

    • getDocuments

      static <T> Collection<T> getDocuments(Collection<?> ids, Class<T> collection)
      Gets a collection of documents by their IDs from the given collection type.

    • getDocuments

      static <T> Collection<T> getDocuments(Collection<?> ids, Object collection, Class<T> type)
      Gets a collection of documents by their IDs, converting the matching documents to value with the given type.

    • deleteDocument

      static CompletableFuture<Void> deleteDocument(Object id, Object collection)
      Deletes the document with given id in given collection if it exists.

    • deleteCollection

      static CompletableFuture<Void> deleteCollection(Object collection)
      Deletes a search collection if it exists.

    • filterContent

      static <T> T filterContent(T value, User user)
      Modify given value before it's passed to the given viewer. See FilterContent for info on how to filter the value.

    • downcast

      static Object downcast(Object object, int desiredRevision)
      Downcasts the given object to a previous revision.
      Parameters:
      object - the object to downcast
      desiredRevision - the target revision
      Returns:
      a serialized form of the object downcasted to the given revision

    • downcast

      static Object downcast(Data<?> data, int desiredRevision)
      Downcasts a Data object to the specified revision level.
      Parameters:
      data - the serialized data
      desiredRevision - the target revision number
      Returns:
      a serialized form of the object downcasted to the given revision

    • registerHandlers

      default Registration registerHandlers(Object... handlers)
      Registers given handlers and initiates message tracking (i.e. listening for messages).

      The given handlers will be inspected for annotated handler methods (e.g. methods annotated with HandleCommand). Depending on this inspection message tracking will commence for any handled message types. To stop listening at any time invoke Registration.cancel() on the returned object.

      Note that an exception may be thrown if tracking for a given message type is already in progress.

      If any of the handlers is a local handler or contains local handler methods, i.e. if type or method is annotated with LocalHandler, the target object will (also) be registered as local handler. Local handlers will handle messages in the publishing thread. If a published message can be handled locally it will not be published to the Fluxzero Runtime. Local handling of messages may come in handy in several situations: e.g. when the message is expressly meant to be handled only by the current application or if the message needs to be handled as quickly as possible. However, in most cases it will not be necessary to register local handlers.

      Note that it will generally not be necessary to invoke this method manually if you use Spring to configure your application.

      See Also:

    • registerHandlers

      default Registration registerHandlers(List<?> handlers)
      Registers given handlers and initiates message tracking.
      See Also:

    • withClock

      void withClock(Clock clock)
      Have Fluxzero use the given Clock when generating timestamps, e.g. when creating a Message.

    • aggregateRepository

      AggregateRepository aggregateRepository()
      Returns a client to assist with event sourcing.

    • eventStore

      EventStore eventStore()
      Returns the store for aggregate events.

    • snapshotStore

      SnapshotStore snapshotStore()
      Returns the store for aggregate snapshots.

    • messageScheduler

      MessageScheduler messageScheduler()
      Returns the gateway to schedule messages.
      See Also:

    • commandGateway

      CommandGateway commandGateway()
      Returns the gateway for command messages.

    • queryGateway

      QueryGateway queryGateway()
      Returns the gateway for query messages.

    • eventGateway

      EventGateway eventGateway()
      Returns the message gateway for application events. Use aggregateRepository() to publish events belonging to an aggregate.

    • resultGateway

      ResultGateway resultGateway()
      Returns the gateway for result messages sent by handlers of commands and queries.

    • errorGateway

      ErrorGateway errorGateway()
      Returns the gateway for any error messages published while handling a command or query.

    • metricsGateway

      MetricsGateway metricsGateway()
      Returns the gateway for metrics events. Metrics events can be published in any form to log custom performance metrics about an application.

    • webRequestGateway

      WebRequestGateway webRequestGateway()
      Returns the gateway for sending web requests.

    • customGateway

      GenericGateway customGateway(String topic)
      Returns the gateway for given custom message topic.

    • tracking

      Tracking tracking(MessageType messageType)
      Returns a client to assist with the tracking of a given message type.

    • keyValueStore

      KeyValueStore keyValueStore()
      Returns a client for the key value service offered by Fluxzero.

    • documentStore

      DocumentStore documentStore()
      Returns a client for the document search service offered by Fluxzero.

    • userProvider

      UserProvider userProvider()
      Returns the UserProvider used by Fluxzero to authenticate users. May be null if user authentication is disabled.

    • cache

      Cache cache()
      Returns the cache used by the client to cache aggregates etc.

    • correlationDataProvider

      CorrelationDataProvider correlationDataProvider()
      Returns the provider of correlation data for published messages.

    • serializer

      Serializer serializer()
      Returns the default serializer

    • clock

      Clock clock()
      Returns the clock used by Fluxzero to generate timestamps.

    • identityProvider

      IdentityProvider identityProvider()
      Returns the factory used by Fluxzero to generate identifiers.

    • propertySource

      PropertySource propertySource()
      Returns the PropertySource configured for this Fluxzero instance.

    • taskScheduler

      TaskScheduler taskScheduler()
      Returns the TaskScheduler of this Fluxzero instance.

    • configuration

      FluxzeroConfiguration configuration()
      Returns the FluxzeroConfiguration of this Fluxzero instance.

    • client

      Client client()
      Returns the low level client used by this Fluxzero instance to interface with the Fluxzero Runtime. Of course the returned client may also be a stand-in for the actual service.

    • apply

      default <R> R apply(ThrowingFunction<Fluxzero,R> function)
      Applies the given function with this Fluxzero set as current threadlocal instance.

    • execute

      default void execute(ThrowingConsumer<Fluxzero> task)
      Executes the given task with this Fluxzero set as current threadlocal instance.

    • beforeShutdown

      Registration beforeShutdown(Runnable task)
      Register a task to run before this Fluxzero instance is closed.

    • close

      default void close()
      Closes this Fluxzero instance gracefully.
      Specified by:
      close in interface AutoCloseable

    • close

      void close(boolean silently)
      Closes this Fluxzero instance gracefully. If silently is true, shutdown is done without logging.