Package app.portaki.sdk.module.backend.run

Class ModuleRunPipeline<C>

java.lang.Object

app.portaki.sdk.module.backend.run.ModuleRunPipeline<C>

public final class ModuleRunPipeline<C>
extends Object

Enchaîne des ModuleRunStep sur un ModuleRunContext et un carry mutable C.

Orchestration in-process uniquement : pas de persistance saga, pas d’appel au cœur Portaki, pas d’Axon. Les ModuleRunListener servent à l’observabilité.

Method Summary

Modifier and Type	Method	Description
ModuleRunReport	execute(ModuleRunContext ctx, C carry)	Exécute toutes les étapes dans l’ordre.
static <C> ModuleRunPipeline<C>	of(ModuleRunStep<C>... steps)
ModuleRunPipeline<C>	withListeners(ModuleRunListener... listeners)

Methods inherited from class java.lang.Object

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

Method Details

of

@SafeVarargs
public static <C> ModuleRunPipeline<C> of(ModuleRunStep<C>... steps)

withListeners

public ModuleRunPipeline<C> withListeners(ModuleRunListener... listeners)

execute

public ModuleRunReport execute(ModuleRunContext ctx,
 C carry)
                        throws ModuleBackendException

Exécute toutes les étapes dans l’ordre. Propage ModuleBackendException telle quelle.

Throws:

ModuleBackendException