Uses of Class
io.fluxcapacitor.common.api.SerializedMessage

Packages that use SerializedMessage

Package	Description
io.fluxcapacitor.common.api
io.fluxcapacitor.common.api.tracking
io.fluxcapacitor.common.tracking

Uses of SerializedMessage in io.fluxcapacitor.common.api

Methods in io.fluxcapacitor.common.api that return SerializedMessage

Modifier and Type	Method	Description
SerializedMessage	SerializedMessage.withData(@NonNull Data<byte[]> data)

Uses of SerializedMessage in io.fluxcapacitor.common.api.tracking

Methods in io.fluxcapacitor.common.api.tracking with parameters of type SerializedMessage

Modifier and Type	Method	Description
boolean	Position.isNewMessage(SerializedMessage message)

Uses of SerializedMessage in io.fluxcapacitor.common.tracking

Methods in io.fluxcapacitor.common.tracking that return SerializedMessage

Modifier and Type	Method	Description
protected SerializedMessage	DefaultTrackingStrategy.ensureMessageSegment(SerializedMessage message)

Methods in io.fluxcapacitor.common.tracking that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected List<SerializedMessage>	DefaultTrackingStrategy.getBatch(int[] segment, Position position, int batchSize)
default List<SerializedMessage>	MessageStore.getBatch(Long minIndex, int maxSize)
List<SerializedMessage>	MessageStore.getBatch(Long minIndex, int maxSize, boolean inclusive)

Methods in io.fluxcapacitor.common.tracking with parameters of type SerializedMessage

Modifier and Type	Method	Description
default CompletableFuture<Void>	MessageStore.append(SerializedMessage... messages)
default boolean	Tracker.canHandle(SerializedMessage message, int[] segmentRange)
protected SerializedMessage	DefaultTrackingStrategy.ensureMessageSegment(SerializedMessage message)

Method parameters in io.fluxcapacitor.common.tracking with type arguments of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	MessageStore.append(List<SerializedMessage> messages)
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected void	DefaultTrackingStrategy.onUpdate(List<SerializedMessage> messages)