SubscribedEntry

What a handler receives: one committed stream (its ref, version, scope and events), at its log position, with its events as the subscription's EntryDecoder read them and the transport metadata appended with it.

SubscriptionRuntime.retry hands over the same position and transport as the tail: it reads the aggregate's entries by version with me.ahoo.wow.spi.log.EventLog.readEntries, so the reservation subscription confirms the keys of a parked aggregate too. position is null only for an entry made by hand. A handler that needs an idempotency key uses (ref, version).

An entry made by EntryDecoder.stateEvents also reads the aggregate's state after the stream, when its handler asks for it: a handler that does not need it (the snapshot subscription, when the store already holds the version) never rebuilds it.

An entry read from another context's published topic carries the record it was read as, published: the state after the stream (null when the upstream publishes without it) and the events as published. stream holds the same facts; position is then the record's partition and its offset plus one.

An entry of a topic of commands or receipts (–) carries the message it was read as: the command the context's intake executes, or the receipt of a command another context rejected. Its stream only names the aggregate whose lane it runs in; nothing was committed.

imported marks history migrate-data imported from 9.x: a log entry at or before the context's cut-over (me.ahoo.wow.spi.subscription.ImportCutover), or a record a peer published as imported. 9.x already acted on it.