Uses of Interface
org.axonframework.domain.DomainEventStream

Packages that use DomainEventStream

org.axonframework.commandhandling.disruptor
org.axonframework.domain	The domain components of the Axon Framework, mainly the Aggregates and Events.
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.eventstore.fs	Package containing classes necessary to implement a FileSystem based implementation of the EventStore
org.axonframework.eventstore.jdbc	JDBC Implementation of the EventStore.
org.axonframework.eventstore.jpa	JPA Implementation of the EventStore.
org.axonframework.eventstore.mongo
org.axonframework.eventstore.supporting
org.axonframework.gae.eventstore
org.axonframework.mongo3.eventstore
org.axonframework.quickstart

Uses of DomainEventStream in org.axonframework.commandhandling.disruptor

Methods in org.axonframework.commandhandling.disruptor that return DomainEventStream

DomainEventStream

DisruptorUnitOfWork.getEventsToStore() Returns the events that need to be stored as part of this Unit of Work.

Uses of DomainEventStream in org.axonframework.domain

Classes in org.axonframework.domain that implement DomainEventStream

class

SimpleDomainEventStream Creates a DomainEventStream that streams the contents of a list.

Methods in org.axonframework.domain that return DomainEventStream

static DomainEventStream	SimpleDomainEventStream.emptyStream() Creates an empty stream.
DomainEventStream	EventContainer.getEventStream() Read the events inside this container using a DomainEventStream.
DomainEventStream	AggregateRoot.getUncommittedEvents() Returns a DomainEventStream to the events in the aggregate that have been raised since creation or the last commit.
DomainEventStream	AbstractAggregateRoot.getUncommittedEvents() Returns a DomainEventStream to the events in the aggregate that have been raised since creation or the last commit.

Uses of DomainEventStream in org.axonframework.eventsourcing

Methods in org.axonframework.eventsourcing that return DomainEventStream

DomainEventStream	EventStreamDecorator.decorateForAppend(String aggregateType, EventSourcedAggregateRoot aggregate, DomainEventStream eventStream) Called when an event stream is appended to the event store.
DomainEventStream	EventCountSnapshotterTrigger.decorateForAppend(String aggregateType, EventSourcedAggregateRoot aggregate, DomainEventStream eventStream)
DomainEventStream	CompositeEventStreamDecorator.decorateForAppend(String aggregateType, EventSourcedAggregateRoot aggregate, DomainEventStream eventStream)
DomainEventStream	EventStreamDecorator.decorateForRead(String aggregateType, Object aggregateIdentifier, DomainEventStream eventStream) Called when an event stream is read from the event store.
DomainEventStream	EventCountSnapshotterTrigger.decorateForRead(String aggregateType, Object aggregateIdentifier, DomainEventStream eventStream)
DomainEventStream	CompositeEventStreamDecorator.decorateForRead(String aggregateType, Object aggregateIdentifier, DomainEventStream eventStream)

Methods in org.axonframework.eventsourcing with parameters of type DomainEventStream

protected DomainEventMessage	AggregateSnapshotter.createSnapshot(String typeIdentifier, Object aggregateIdentifier, DomainEventStream eventStream)
protected abstract DomainEventMessage	AbstractSnapshotter.createSnapshot(String typeIdentifier, Object aggregateIdentifier, DomainEventStream eventStream) Creates a snapshot event for an aggregate of the given typeIdentifier of which passed events are available in the given eventStream.
DomainEventStream	EventStreamDecorator.decorateForAppend(String aggregateType, EventSourcedAggregateRoot aggregate, DomainEventStream eventStream) Called when an event stream is appended to the event store.
DomainEventStream	EventCountSnapshotterTrigger.decorateForAppend(String aggregateType, EventSourcedAggregateRoot aggregate, DomainEventStream eventStream)
DomainEventStream	CompositeEventStreamDecorator.decorateForAppend(String aggregateType, EventSourcedAggregateRoot aggregate, DomainEventStream eventStream)
DomainEventStream	EventStreamDecorator.decorateForRead(String aggregateType, Object aggregateIdentifier, DomainEventStream eventStream) Called when an event stream is read from the event store.
DomainEventStream	EventCountSnapshotterTrigger.decorateForRead(String aggregateType, Object aggregateIdentifier, DomainEventStream eventStream)
DomainEventStream	CompositeEventStreamDecorator.decorateForRead(String aggregateType, Object aggregateIdentifier, DomainEventStream eventStream)
void	EventSourcedAggregateRoot.initializeState(DomainEventStream domainEventStream) Initialize the state of this aggregate using the events in the provided DomainEventStream.
void	AbstractEventSourcedAggregateRoot.initializeState(DomainEventStream domainEventStream) Initialize the state of this aggregate using the events in the provided DomainEventStream.
protected void	EventSourcingRepository.resolveConflicts(T aggregate, DomainEventStream unseenEvents) Resolve (potential) conflicts for the given aggregate, where given unseenEvents may have been concurrently applied.

Uses of DomainEventStream in org.axonframework.eventstore

Methods in org.axonframework.eventstore that return DomainEventStream

DomainEventStream	EventStore.readEvents(String type, Object identifier) Read the events of the aggregate identified by the given type and identifier that allow the current aggregate state to be rebuilt.
DomainEventStream	PartialStreamSupport.readEvents(String type, Object identifier, long firstSequenceNumber) Returns a Stream containing events for the aggregate identified by the given type and identifier, starting at the event with the given firstSequenceNumber (included).
DomainEventStream	PartialStreamSupport.readEvents(String type, Object identifier, long firstSequenceNumber, long lastSequenceNumber) Returns a Stream containing events for the aggregate identified by the given type and identifier, starting at the event with the given firstSequenceNumber (included) up to and including the event with given lastSequenceNumber.

Methods in org.axonframework.eventstore with parameters of type DomainEventStream

void	EventStore.appendEvents(String type, DomainEventStream events) Append the events in the given stream to the event store.

Uses of DomainEventStream in org.axonframework.eventstore.fs

Classes in org.axonframework.eventstore.fs that implement DomainEventStream

class

FileSystemBufferedReaderDomainEventStream DomainEventStream implementation that reads DomainEvents from the filesystem using an InputStream.

Methods in org.axonframework.eventstore.fs that return DomainEventStream

DomainEventStream

FileSystemEventStore.readEvents(String type, Object aggregateIdentifier)

Methods in org.axonframework.eventstore.fs with parameters of type DomainEventStream

void	FileSystemEventStore.appendEvents(String type, DomainEventStream eventsToStore) Append the events in the given stream to the event store.

Uses of DomainEventStream in org.axonframework.eventstore.jdbc

Methods in org.axonframework.eventstore.jdbc that return DomainEventStream

DomainEventStream	JdbcEventStore.readEvents(String type, Object identifier) Read the events of the aggregate identified by the given type and identifier that allow the current aggregate state to be rebuilt.
DomainEventStream	JdbcEventStore.readEvents(String type, Object identifier, long firstSequenceNumber)
DomainEventStream	JdbcEventStore.readEvents(String type, Object identifier, long firstSequenceNumber, long lastSequenceNumber)

Methods in org.axonframework.eventstore.jdbc with parameters of type DomainEventStream

void	JdbcEventStore.appendEvents(String type, DomainEventStream events) Append the events in the given stream to the event store.

Uses of DomainEventStream in org.axonframework.eventstore.jpa

Methods in org.axonframework.eventstore.jpa that return DomainEventStream

DomainEventStream	JpaEventStore.readEvents(String type, Object identifier) Read the events of the aggregate identified by the given type and identifier that allow the current aggregate state to be rebuilt.
DomainEventStream	JpaEventStore.readEvents(String type, Object identifier, long firstSequenceNumber)
DomainEventStream	JpaEventStore.readEvents(String type, Object identifier, long firstSequenceNumber, long lastSequenceNumber)

Methods in org.axonframework.eventstore.jpa with parameters of type DomainEventStream

void	JpaEventStore.appendEvents(String type, DomainEventStream events) Append the events in the given stream to the event store.

Uses of DomainEventStream in org.axonframework.eventstore.mongo

Methods in org.axonframework.eventstore.mongo that return DomainEventStream

DomainEventStream	MongoEventStore.readEvents(String type, Object identifier)
DomainEventStream	MongoEventStore.readEvents(String type, Object identifier, long firstSequenceNumber)
DomainEventStream	MongoEventStore.readEvents(String type, Object identifier, long firstSequenceNumber, long lastSequenceNumber)

Methods in org.axonframework.eventstore.mongo with parameters of type DomainEventStream

void	MongoEventStore.appendEvents(String type, DomainEventStream events)

Uses of DomainEventStream in org.axonframework.eventstore.supporting

Methods in org.axonframework.eventstore.supporting that return DomainEventStream

DomainEventStream	VolatileEventStore.readEvents(String type, Object identifier)
DomainEventStream	TimestampCutoffReadonlyEventStore.readEvents(String type, Object identifier)
DomainEventStream	SequenceEventStore.readEvents(String type, Object identifier)

Methods in org.axonframework.eventstore.supporting with parameters of type DomainEventStream

void	VolatileEventStore.appendEvents(String type, DomainEventStream events)
void	TimestampCutoffReadonlyEventStore.appendEvents(String type, DomainEventStream events)
void	SequenceEventStore.appendEvents(String type, DomainEventStream events)

Uses of DomainEventStream in org.axonframework.gae.eventstore

Methods in org.axonframework.gae.eventstore that return DomainEventStream

DomainEventStream

GaeEventStore.readEvents(String type, Object identifier)

Methods in org.axonframework.gae.eventstore with parameters of type DomainEventStream

void	GaeEventStore.appendEvents(String type, DomainEventStream events)

Uses of DomainEventStream in org.axonframework.mongo3.eventstore

Methods in org.axonframework.mongo3.eventstore that return DomainEventStream

DomainEventStream	MongoEventStore.readEvents(String type, Object identifier)
DomainEventStream	MongoEventStore.readEvents(String type, Object identifier, long firstSequenceNumber)
DomainEventStream	MongoEventStore.readEvents(String type, Object identifier, long firstSequenceNumber, long lastSequenceNumber)

Methods in org.axonframework.mongo3.eventstore with parameters of type DomainEventStream

void	MongoEventStore.appendEvents(String type, DomainEventStream events)

Uses of DomainEventStream in org.axonframework.quickstart

Methods in org.axonframework.quickstart that return DomainEventStream

DomainEventStream

RunEventReplay.StubEventStore.readEvents(String type, Object identifier)

Methods in org.axonframework.quickstart with parameters of type DomainEventStream

void	RunEventReplay.StubEventStore.appendEvents(String type, DomainEventStream events)