Package io.fluxcapacitor.javaclient.tracking.handling

Class Invocation

java.lang.Object
io.fluxcapacitor.javaclient.tracking.handling.Invocation
public class Invocation extends Object
Tracks the lifecycle and identity of a single message handler invocation.

This class enables consistent tagging and correlation of all side effects (e.g. metrics, queries, event sourcing, message publication) produced during the execution of a handler. Each invocation is assigned a unique

invalid reference 
invocation ID
which is automatically added to metadata and logging contexts to trace functional and non-functional effects back to the triggering message.

Automatic Invocation Wrapping

The Flux Capacitor client automatically wraps all handler invocations using this class. This includes:
  • Local handlers (i.e. message handling in the publishing thread)
  • Tracked handlers (i.e. message tracking via the Flux platform)

As a result, developers typically do not need to call performInvocation(Callable) directly, unless they are manually invoking a handler outside of the Flux infrastructure.

Usage

When used manually, wrap handler logic with performInvocation(Callable) to activate an invocation context: 

 Invocation.performInvocation(() -> {
     // handler logic
     FluxCapacitor.publishEvent(new SomeEvent());
     return result;
 });

This ensures:

  • A consistent invocation ID is available throughout the thread
  • Any emitted messages, metrics, or queries can include that ID as a correlation token
  • Callbacks can be registered via whenHandlerCompletes(BiConsumer) to react to success/failure
See Also:

  • Constructor Details

    • Invocation

      public Invocation()

  • Method Details

    • performInvocation

      public static <V> V performInvocation(Callable<V> callable)
      Wraps the given Callable in an invocation context.

      This method ensures that callbacks registered via whenHandlerCompletes(BiConsumer) are executed upon completion of the callable.

      Parameters:
      callable - the task to run
      Returns:
      the callable result

    • getCurrent

      public static Invocation getCurrent()
      Returns the current Invocation bound to this thread, or null if none exists.

    • whenHandlerCompletes

      public static Registration whenHandlerCompletes(BiConsumer<Object,Throwable> callback)
      Registers a callback to be executed when the current handler invocation completes.

      If no invocation is active, the callback is executed immediately with null values.

      Parameters:
      callback - the handler result/error consumer
      Returns:
      a Registration handle to cancel the callback