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

Interface Appender

  • All Known Implementing Classes:
    TransformationStreamAppender
    public interface Appender
    Appends the transformation actions.
    Since:
    2023.1.0
    Author:
    Sara Pellegrini

    • Method Detail

      • deleteEvent

        CompletableFuture<Appender> deleteEvent​(long token)
        Appends to the transformation the request to delete the event with the given token.
        Parameters:
        token - the token of the event to be deleted
        Returns:
        a CompletableFuture of the Appender, used for composition

      • replaceEvent

        CompletableFuture<Appender> replaceEvent​(long token,
                                         Event replacement)
        Appends to the transformation the request to replace the event with the given token.
        Parameters:
        token - the token of the event to be replaced
        replacement - the new event used to replace the original one
        Returns:
        a CompletableFuture of the Appender, used for composition