org.axonframework.axonserver.connector.event

Class AxonServerEventStoreClient

java.lang.Object

org.axonframework.axonserver.connector.event.AxonServerEventStoreClient

public class AxonServerEventStoreClient
extends Object

Generic client for EventStore through AxonServer. Does not require any Axon framework classes.

Constructor Summary

Constructors

Constructor and Description
AxonServerEventStoreClient(AxonServerConfiguration eventStoreConfiguration, AxonServerConnectionManager axonServerConnectionManager) Initialize the Event Store Client using given eventStoreConfiguration and given platformConnectionManager.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Confirmation>	appendSnapshot(Event snapshot)
AppendEventTransaction	createAppendEventConnection()
CompletableFuture<TrackingToken>	getFirstToken()
CompletableFuture<TrackingToken>	getLastToken()
CompletableFuture<TrackingToken>	getTokenAt(Instant instant)
CompletableFuture<ReadHighestSequenceNrResponse>	lastSequenceNumberFor(String aggregateIdentifier)
Stream<Event>	listAggregateEvents(GetAggregateEventsRequest request) Retrieves the events for an aggregate described in given request.
Stream<Event>	listAggregateSnapshots(GetAggregateSnapshotsRequest request)
io.grpc.stub.StreamObserver<GetEventsRequest>	listEvents(io.grpc.stub.StreamObserver<EventWithToken> responseStreamObserver) Provide a list of events by using a StreamObserver for type GetEventsRequest.
io.grpc.stub.StreamObserver<QueryEventsRequest>	query(io.grpc.stub.StreamObserver<QueryEventsResponse> responseStreamObserver)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonServerEventStoreClient

public AxonServerEventStoreClient(AxonServerConfiguration eventStoreConfiguration,
                                  AxonServerConnectionManager axonServerConnectionManager)

Initialize the Event Store Client using given eventStoreConfiguration and given platformConnectionManager.

Parameters:

eventStoreConfiguration - The configuration describing the bounded context that this application operates in

axonServerConnectionManager - manager for connections to AxonServer platform

Method Detail

shutdown

public void shutdown()

listAggregateEvents

public Stream<Event> listAggregateEvents(GetAggregateEventsRequest request)
                                  throws ExecutionException,
                                         InterruptedException

Retrieves the events for an aggregate described in given request.

Parameters:

request - The request describing the aggregate to retrieve messages for

Returns:

a Stream providing access to Events published by the aggregate described in the request

Throws:

ExecutionException - when an error was reported while reading events

InterruptedException - when the thread was interrupted while reading events from the server

listEvents

public io.grpc.stub.StreamObserver<GetEventsRequest> listEvents(io.grpc.stub.StreamObserver<EventWithToken> responseStreamObserver)

Provide a list of events by using a StreamObserver for type GetEventsRequest.

Parameters:

responseStreamObserver - a StreamObserver for messages from the server

Returns:

the StreamObserver to send request messages to server with

appendSnapshot

public CompletableFuture<Confirmation> appendSnapshot(Event snapshot)

getLastToken

public CompletableFuture<TrackingToken> getLastToken()

getFirstToken

public CompletableFuture<TrackingToken> getFirstToken()

getTokenAt

public CompletableFuture<TrackingToken> getTokenAt(Instant instant)

createAppendEventConnection

public AppendEventTransaction createAppendEventConnection()

query

public io.grpc.stub.StreamObserver<QueryEventsRequest> query(io.grpc.stub.StreamObserver<QueryEventsResponse> responseStreamObserver)

lastSequenceNumberFor

public CompletableFuture<ReadHighestSequenceNrResponse> lastSequenceNumberFor(String aggregateIdentifier)

listAggregateSnapshots

public Stream<Event> listAggregateSnapshots(GetAggregateSnapshotsRequest request)
                                     throws ExecutionException,
                                            InterruptedException

Throws:

ExecutionException

InterruptedException