Class GetEvents

java.lang.Object

io.fluxzero.common.api.Request

io.fluxzero.common.api.eventsourcing.GetEvents

All Implemented Interfaces:

JsonType

public class GetEvents
extends Request

A request to fetch stored events for a specific aggregate in an event-sourced system.

This class is used by the Fluxzero Runtime to retrieve historical events from the event store associated with a given aggregate. It supports pagination via lastSequenceNumber, batchSize, and maxBytes to efficiently load large event streams.

Usage

Typically used when:

• Reconstructing an aggregate's state from its event history
• Streaming events for external use or replay

Example

GetEvents request = new GetEvents("order-123", 50L, 100, 104_857_600L);

See Also:

• SerializedMessage
• GetEventsResult

Constructor Summary

Constructors

Constructor	Description
GetEvents(String aggregateId, Long lastSequenceNumber, int batchSize)	Creates a count-bounded request without a payload-byte limit.
GetEvents(String aggregateId, Long lastSequenceNumber, int batchSize, long maxBytes)

Method Summary

Methods inherited from class Object

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

Methods inherited from interface JsonType

toMetric

Constructor Details

GetEvents

@ConstructorProperties({"aggregateId","lastSequenceNumber","batchSize","maxBytes"})
public GetEvents(String aggregateId,
 Long lastSequenceNumber,
 int batchSize,
 long maxBytes)

GetEvents

public GetEvents(String aggregateId,
 Long lastSequenceNumber,
 int batchSize)

Creates a count-bounded request without a payload-byte limit.