Class DocumentMessageReader

java.lang.Object

io.fluxzero.sdk.persisting.search.DocumentMessageReader

public final class DocumentMessageReader
extends Object

Internal, registration-scoped document reader. Retains the original composition for typed Graph handlers while preserving the ordinary logical message, handler selection, payload parameters and interceptor input. The root's upcast payload is reused; descendant paths and revisions always refer to the original composition. Explicit internal Model-source handlers also require exactly one upcast state; ordinary document streams retain split/drop semantics. Registrations are reference-counted and removed with their handlers.

Constructor Summary

Constructors

Constructor	Description
DocumentMessageReader()

Method Summary

Modifier and Type	Method	Description
Stream<DeserializingMessage>	read(List<io.fluxzero.common.api.SerializedMessage> messages, String topic, Serializer serializer)	Reads a batch; topics without typed Graph handlers retain the original serializer stream.
boolean	readsGraphs(String topic)	Whether this collection needs the original composition alongside its logical document payload.
io.fluxzero.common.Registration	register(Object target, io.fluxzero.common.handling.HandlerFilter filter)	Records accepted typed Graph and Model-source methods until the returned registration is cancelled.

Methods inherited from class Object

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

Constructor Details

DocumentMessageReader

public DocumentMessageReader()

Method Details

register

public io.fluxzero.common.Registration register(Object target,
 io.fluxzero.common.handling.HandlerFilter filter)

Records accepted typed Graph and Model-source methods until the returned registration is cancelled.

readsGraphs

public boolean readsGraphs(String topic)

Whether this collection needs the original composition alongside its logical document payload.

read

public Stream<DeserializingMessage> read(List<io.fluxzero.common.api.SerializedMessage> messages,
 String topic,
 Serializer serializer)

Reads a batch; topics without typed Graph handlers retain the original serializer stream.