Package io.axoniq.framework.messaging.transformation.events

Class EventTransformerChain.Builder

java.lang.Object

io.axoniq.framework.messaging.transformation.events.EventTransformerChain.Builder

Enclosing class:

EventTransformerChain

public static final class EventTransformerChain.Builder
extends Object

Fluent builder for EventTransformerChain. An exact from match takes precedence over a predicate match independent of registration order. Predicates are consulted only when no exact match applies, in registration order. build() produces a new, immutable EventTransformerChain; configuration is startup-only, so register(EventTransformation) and maxIterationsPerEvent(int) calls after build() are rejected.

maxIterationsPerEvent(int) caps how many times the chain re-applies transformations to a single event during fixed-point chaining (default EventTransformerChain.DEFAULT_MAX_ITERATIONS_PER_EVENT); it guards against a self-matching or cyclic configuration and otherwise never fires.

Not thread-safe: build the chain on a single thread at startup, then share the resulting EventTransformerChain (which is immutable and concurrent-safe).

Method Summary

Modifier and Type	Method	Description
EventTransformerChain	build()	Builds and returns the immutable chain.
EventTransformerChain.Builder	maxIterationsPerEvent(int max)	Sets the per-event iteration safety bound.
EventTransformerChain.Builder	register(EventTransformation transformation)	Register an EventTransformation with the chain.

Methods inherited from class java.lang.Object

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

Method Details

maxIterationsPerEvent

public EventTransformerChain.Builder maxIterationsPerEvent(int max)

Sets the per-event iteration safety bound. Defaults to EventTransformerChain.DEFAULT_MAX_ITERATIONS_PER_EVENT.

Parameters:

max - the new safety bound, strictly positive

Returns:

this builder

Throws:

ChainConfigurationException - if build() has already been called

AxonConfigurationException - if max is not strictly positive

register

public EventTransformerChain.Builder register(EventTransformation transformation)

Register an EventTransformation with the chain.

A payload mapping with an exact from may change only the version, never the QualifiedName; such a name change is rejected here, at registration time. Use EventTransformation.rename(MessageType, MessageType) to change the name.

Parameters:

transformation - the transformation to add

Returns:

this builder

Throws:

ChainConfigurationException - if build() has already been called, or if transformation is a payload mapping whose exact from and to qualified names differ

build

public EventTransformerChain build()

Builds and returns the immutable chain.

Returns:

the built chain

Throws:

ChainConfigurationException - if two transformations match the same exact source identity