Module io.axoniq.connector.axonserver

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

Class AppendEventsTransactionImpl

java.lang.Object

io.axoniq.axonserver.connector.event.impl.AppendEventsTransactionImpl

All Implemented Interfaces:

AppendEventsTransaction

public class AppendEventsTransactionImpl
extends Object
implements AppendEventsTransaction

Implementation of the AppendEventsTransaction used to append events to the Event Store.

Constructor Summary

Constructors

Constructor	Description
AppendEventsTransactionImpl(io.grpc.stub.StreamObserver<Event> stream, CompletableFuture<ConfirmationWithConsistencyMarker> result)	Constructs a AppendEventsTransactionImpl used to append events to the Event Store.

Method Summary

Modifier and Type	Method	Description
AppendEventsTransaction	appendEvent(Event event)	Append the given event to be committed as part of this transaction.
CompletableFuture<ConfirmationWithConsistencyMarker>	commit()	Commit this transaction, appending all registered events into the Event Store.
void	rollback()	Rolls back the transaction.

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendEventsTransactionImpl

public AppendEventsTransactionImpl(io.grpc.stub.StreamObserver<Event> stream,
                                   CompletableFuture<ConfirmationWithConsistencyMarker> result)

Constructs a AppendEventsTransactionImpl used to append events to the Event Store.

Parameters:

stream - the StreamObserver of Event instances which should be appended

result - a CompletableFuture resolving the ConfirmationWithConsistencyMarker of the successful processing of this transaction

Method Detail

appendEvent

public AppendEventsTransaction appendEvent(Event event)

Description copied from interface: AppendEventsTransaction

Append the given event to be committed as part of this transaction.

Specified by:

appendEvent in interface AppendEventsTransaction

Parameters:

event - the event to append

Returns:

this instance for fluent interfacing

commit

public CompletableFuture<ConfirmationWithConsistencyMarker> commit()

Description copied from interface: AppendEventsTransaction

Commit this transaction, appending all registered events into the Event Store.

Specified by:

commit in interface AppendEventsTransaction

Returns:

a CompletableFuture resolving the confirmation of the successful processing of the transaction

rollback

public void rollback()

Description copied from interface: AppendEventsTransaction

Rolls back the transaction.

Specified by:

rollback in interface AppendEventsTransaction