org.axonframework.axonserver.connector.event

Class AppendEventTransaction

java.lang.Object

org.axonframework.axonserver.connector.event.AppendEventTransaction

public class AppendEventTransaction
extends Object

Sends one or more events to AxonServer in a single transaction.

Constructor Summary

Constructors

Constructor and Description
AppendEventTransaction(int timeout, io.grpc.stub.StreamObserver<Event> eventStreamObserver, CompletableFuture<Confirmation> observer, EventCipher eventCipher)

Method Summary

Modifier and Type	Method and Description
void	append(Event event)
void	commit()
void	rollback(Throwable reason)

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendEventTransaction

public AppendEventTransaction(int timeout,
                              io.grpc.stub.StreamObserver<Event> eventStreamObserver,
                              CompletableFuture<Confirmation> observer,
                              EventCipher eventCipher)

Method Detail

append

public void append(Event event)

commit

public void commit()
            throws InterruptedException,
                   ExecutionException,
                   TimeoutException

Throws:

InterruptedException

ExecutionException

TimeoutException

rollback

public void rollback(Throwable reason)