Module io.axoniq.connector.axonserver

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

Class GrpcTransformationStream

java.lang.Object

io.axoniq.axonserver.connector.event.transformation.impl.grpc.GrpcTransformationStream

All Implemented Interfaces:

EventTransformationService.TransformationStream

public class GrpcTransformationStream
extends Object
implements EventTransformationService.TransformationStream

Since:

2023.0.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor	Description
GrpcTransformationStream(String transformationId, io.grpc.stub.StreamObserver<TransformRequest> requestStreamObserver, Consumer<Consumer<Long>> ackListenerRegistration, Consumer<Consumer<Throwable>> onCompleteRegistration)

Method Summary

Modifier and Type	Method	Description
void	complete()	Completes the stream.
CompletableFuture<Void>	deleteEvent(long token, long sequence)	Registers the request to delete the event with the specified token.
void	onCompletedByServer(Consumer<Throwable> onCompleted)	Resister a callback function that is invoked when the stream is completed by Axon Server.
CompletableFuture<Void>	replaceEvent(long token, Event event, long sequence)	Registers the request to replace the event with the specified token.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcTransformationStream

public GrpcTransformationStream(String transformationId,
                                io.grpc.stub.StreamObserver<TransformRequest> requestStreamObserver,
                                Consumer<Consumer<Long>> ackListenerRegistration,
                                Consumer<Consumer<Throwable>> onCompleteRegistration)

Method Detail

deleteEvent

public CompletableFuture<Void> deleteEvent(long token,
                                           long sequence)

Description copied from interface: EventTransformationService.TransformationStream

Registers the request to delete the event with the specified token.

Specified by:

deleteEvent in interface EventTransformationService.TransformationStream

Parameters:

token - the token of the event to be deleted

sequence - the expected last sequence of the transformation, used to check that no change request before this one has been lost

Returns:

a CompletableFuture that completes when the request has been received by Axon Server.

replaceEvent

public CompletableFuture<Void> replaceEvent(long token,
                                            Event event,
                                            long sequence)

Description copied from interface: EventTransformationService.TransformationStream

Registers the request to replace the event with the specified token.

Specified by:

replaceEvent in interface EventTransformationService.TransformationStream

Parameters:

token - the token of the event to be replaced

event - the new version of the event, to be used as a replacement for the original one

sequence - the expected last sequence of the transformation, used to check that no change request before this one has been lost

Returns:

a CompletableFuture that completes when the request has been received by Axon Server.

complete

public void complete()

Description copied from interface: EventTransformationService.TransformationStream

Completes the stream.

Specified by:

complete in interface EventTransformationService.TransformationStream

onCompletedByServer

public void onCompletedByServer(Consumer<Throwable> onCompleted)

Description copied from interface: EventTransformationService.TransformationStream

Resister a callback function that is invoked when the stream is completed by Axon Server.

Specified by:

onCompletedByServer in interface EventTransformationService.TransformationStream

Parameters:

onCompleted - the callback function invoked when the stream is completed by Axon Server.