Package org.axonframework.axonserver.connector.event.axon

Class AxonServerEventStore

java.lang.Object
org.axonframework.eventhandling.AbstractEventBus
org.axonframework.eventsourcing.eventstore.AbstractEventStore
org.axonframework.axonserver.connector.event.axon.AxonServerEventStore
All Implemented Interfaces:
org.axonframework.eventhandling.DomainEventSequenceAware, org.axonframework.eventhandling.EventBus, org.axonframework.eventsourcing.eventstore.EventStore, org.axonframework.messaging.MessageDispatchInterceptorSupport<org.axonframework.eventhandling.EventMessage<?>>, org.axonframework.messaging.StreamableMessageSource<org.axonframework.eventhandling.TrackedEventMessage<?>>, org.axonframework.messaging.SubscribableMessageSource<org.axonframework.eventhandling.EventMessage<?>>
public class AxonServerEventStore extends org.axonframework.eventsourcing.eventstore.AbstractEventStore
Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.
Since:
4.0
Author:
Zoltan Altfatter, Marc Gathier, Allard Buijze

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    AxonServerEventStore.Builder
    Builder class to instantiate a AxonServerEventStore.

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    AxonServerEventStore(AxonServerEventStore.Builder builder)
    Instantiate a AxonServerEventStore based on the fields contained in the AxonServerEventStore.Builder.

  • Method Summary

    Modifier and Type
    Method
    Description
    static AxonServerEventStore.Builder
    builder()
    Instantiate a Builder to be able to create a AxonServerEventStore.
    org.axonframework.messaging.StreamableMessageSource<org.axonframework.eventhandling.TrackedEventMessage<?>>
    createStreamableMessageSourceForContext(String context)
    Creates a StreamableMessageSource that streams events from the given context, rather than the default context the application was configured to connect to.
    protected Optional<org.axonframework.eventhandling.DomainEventMessage<?>>
    handleSnapshotReadingError(String aggregateIdentifier, Throwable e)
     
    org.axonframework.eventhandling.TrackingEventStream
    openStream(org.axonframework.eventhandling.TrackingToken trackingToken)
     
    QueryResultStream
    query(String query, boolean liveUpdates)
     
    org.axonframework.eventsourcing.eventstore.DomainEventStream
    readEvents(String aggregateIdentifier)
     
    protected org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.AxonIQEventStorageEngine
    storageEngine()
     

    Methods inherited from class org.axonframework.eventsourcing.eventstore.AbstractEventStore

    createHeadToken, createTailToken, createTokenAt, lastSequenceNumberFor, prepareCommit, readEvents, stagedDomainEventMessages, storeSnapshot

    Methods inherited from class org.axonframework.eventhandling.AbstractEventBus

    afterCommit, commit, intercept, publish, queuedMessages, registerDispatchInterceptor, subscribe

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.axonframework.eventhandling.EventBus

    publish, publish

    Methods inherited from interface org.axonframework.messaging.MessageDispatchInterceptorSupport

    registerDispatchInterceptor

    Methods inherited from interface org.axonframework.messaging.StreamableMessageSource

    createTokenSince

    Methods inherited from interface org.axonframework.messaging.SubscribableMessageSource

    subscribe

  • Constructor Details

  • Method Details

    • builder

      public static AxonServerEventStore.Builder builder()
      Instantiate a Builder to be able to create a AxonServerEventStore.

      The main goal of this Builder is to instantiate an AxonServer specific EventStorageEngine. The properties which may be provided through this Builder are thus all used to end up with that EventStorageEngine implementation. An EventStorageEngine may be provided directly however, although we encourage the usage of the AxonServerEventStore.Builder.configuration and AxonServerEventStore.Builder.axonServerConnectionManager functions to let it be created.

      The EventUpcaster is defaulted to a NoOpEventUpcaster and the EventBusSpanFactory is defaulted to a DefaultEventBusSpanFactory backed by a NoOpSpanFactory.

      The event and snapshot Serializer, AxonServerConfiguration and AxonServerConnectionManager are hard requirements if no EventStorageEngine is provided directly.

      Returns:
      a Builder to be able to create a AxonServerEventStore

    • openStream

      public org.axonframework.eventhandling.TrackingEventStream openStream(org.axonframework.eventhandling.TrackingToken trackingToken)

    • query

      public QueryResultStream query(String query, boolean liveUpdates)

    • storageEngine

      protected org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.AxonIQEventStorageEngine storageEngine()
      Overrides:
      storageEngine in class org.axonframework.eventsourcing.eventstore.AbstractEventStore

    • createStreamableMessageSourceForContext

      public org.axonframework.messaging.StreamableMessageSource<org.axonframework.eventhandling.TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context)
      Creates a StreamableMessageSource that streams events from the given context, rather than the default context the application was configured to connect to.
      Parameters:
      context - the name of the context to create a message source for
      Returns:
      a StreamableMessageSource of TrackedEventMessages tied to the given context

    • handleSnapshotReadingError

      protected Optional<org.axonframework.eventhandling.DomainEventMessage<?>> handleSnapshotReadingError(String aggregateIdentifier, Throwable e)
      Overrides:
      handleSnapshotReadingError in class org.axonframework.eventsourcing.eventstore.AbstractEventStore

    • readEvents

      public org.axonframework.eventsourcing.eventstore.DomainEventStream readEvents(String aggregateIdentifier)
      Specified by:
      readEvents in interface org.axonframework.eventsourcing.eventstore.EventStore
      Overrides:
      readEvents in class org.axonframework.eventsourcing.eventstore.AbstractEventStore