Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.event.transformation.impl

Class DefaultActiveTransformation

java.lang.Object

io.axoniq.axonserver.connector.event.transformation.impl.DefaultActiveTransformation

All Implemented Interfaces:

ActiveTransformation

public class DefaultActiveTransformation
extends Object
implements ActiveTransformation

Default implementation of the ActiveTransformation

Since:

2023.1.0

Author:

Sara Pellegrini

Method Summary

Modifier and Type	Method	Description
CompletableFuture<EventTransformation>	cancel()	Cancels the active transformation.
CompletableFuture<EventTransformation>	startApplying()	Requests the transformation to be applied.
CompletableFuture<ActiveTransformation>	transform(Transformer transformer)	Accepts a Transformer to collect the requested changes and to register them into the active transformation.

Methods inherited from class java.lang.Object

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

Method Detail

transform

public CompletableFuture<ActiveTransformation> transform(Transformer transformer)

Description copied from interface: ActiveTransformation

Accepts a Transformer to collect the requested changes and to register them into the active transformation.

Specified by:

transform in interface ActiveTransformation

Parameters:

transformer - the Transformer used to append the required changes to the active transformation

Returns:

a CompletableFuture of the active transformation that completes when all changes have been registered.

startApplying

public CompletableFuture<EventTransformation> startApplying()

Description copied from interface: ActiveTransformation

Requests the transformation to be applied. After this method is invoked, it will not be possible to cancel the transformation or to register new changes in it. Axon Server will asynchronously apply the transformation to the event store, making the changes effective. The returned CompletableFuture completes when the request to start applying has been received form AS, it does not wait the apply process is completed. Depending on the number of transformation actions contained in the transformation, the apply process can take a long time before to be completed.

Specified by:

startApplying in interface ActiveTransformation

Returns:

a CompletableFuture of the Event Transformation, that completes only after the start applying request has been received by AS.

cancel

public CompletableFuture<EventTransformation> cancel()

Description copied from interface: ActiveTransformation

Cancels the active transformation. After this method is invoked, it will not be possible to apply the transformation or to register new changes in it.

Specified by:

cancel in interface ActiveTransformation

Returns:

a CompletableFuture of the Event Transformation, that completes only after the cancel request has been received by AS.