Uses of Class
io.fluxzero.common.api.tracking.MessageBatch

Packages that use MessageBatch

Package	Description
io.fluxzero.common.tracking
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.tracking.metrics

Uses of MessageBatch in io.fluxzero.common.tracking

Methods in io.fluxzero.common.tracking with parameters of type MessageBatch

Modifier and Type	Method	Description
void	SimpleTracker.send(MessageBatch batch)
void	Tracker.send(MessageBatch batch)	Sends a batch of messages to this tracker.
void	WebSocketTracker.send(MessageBatch batch)
default void	Tracker.sendEmptyBatch(MessageBatch batch)	Sends an empty batch (typically used to signal idle or shutdown).
protected void	DefaultTrackingStrategy.waitForMessages(Tracker tracker, MessageBatch emptyBatch, PositionStore positionStore)
protected void	DefaultTrackingStrategy.waitForUpdate(Tracker tracker, MessageBatch emptyBatch, Runnable followUp)

Constructor parameters in io.fluxzero.common.tracking with type arguments of type MessageBatch

Modifier	Constructor	Description
	SimpleTracker(String consumerName, int maxSize, Consumer<MessageBatch> handler)
	WebSocketTracker(Read read, MessageType messageType, String clientId, String sessionId, Consumer<MessageBatch> handler)

Uses of MessageBatch in io.fluxzero.sdk.tracking

Subinterfaces with type arguments of type MessageBatch in io.fluxzero.sdk.tracking

Modifier and Type	Interface	Description
interface	MappingBatchInterceptor	A BatchInterceptor specialization that transforms a MessageBatch before it is passed to the consumer for processing.
interface	MappingBatchInterceptor	A BatchInterceptor specialization that transforms a MessageBatch before it is passed to the consumer for processing.

Methods in io.fluxzero.sdk.tracking that return MessageBatch

Modifier and Type	Method	Description
MessageBatch	MappingBatchInterceptor.apply(MessageBatch messageBatch, Tracker tracker)	Applies a transformation to the given MessageBatch, optionally modifying its contents or structure.

Methods in io.fluxzero.sdk.tracking that return types with arguments of type MessageBatch

Modifier and Type	Method	Description
Consumer<MessageBatch>	BatchInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)	Intercepts the given batch message consumer and returns a decorated version to be invoked by the tracker.
Consumer<MessageBatch>	FluxzeroInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)
default Consumer<MessageBatch>	MappingBatchInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)	Wraps the batch processing consumer with a transformation step that rewrites the batch before processing.
Consumer<MessageBatch>	StallingBatchInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)

Methods in io.fluxzero.sdk.tracking with parameters of type MessageBatch

Modifier and Type	Method	Description
MessageBatch	MappingBatchInterceptor.apply(MessageBatch messageBatch, Tracker tracker)	Applies a transformation to the given MessageBatch, optionally modifying its contents or structure.

Method parameters in io.fluxzero.sdk.tracking with type arguments of type MessageBatch

Modifier and Type	Method	Description
Consumer<MessageBatch>	BatchInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)	Intercepts the given batch message consumer and returns a decorated version to be invoked by the tracker.
Consumer<MessageBatch>	FluxzeroInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)
default Consumer<MessageBatch>	MappingBatchInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)	Wraps the batch processing consumer with a transformation step that rewrites the batch before processing.
Consumer<MessageBatch>	StallingBatchInterceptor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)

Uses of MessageBatch in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client that return MessageBatch

Modifier and Type	Method	Description
protected MessageBatch	DefaultTracker.fetch(Long lastIndex)
protected MessageBatch	CachingTrackingClient.getMessageBatch(ConsumerConfiguration config, long minIndex, ClaimSegmentResult claim)
default MessageBatch	TrackingClient.readAndWait(String trackerId, Long lastIndex, ConsumerConfiguration configuration)	Reads the next available MessageBatch for the given tracker and blocks until messages are available.

Methods in io.fluxzero.sdk.tracking.client that return types with arguments of type MessageBatch

Modifier and Type	Method	Description
CompletableFuture<MessageBatch>	CachingTrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<MessageBatch>	LocalTrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<MessageBatch>	TrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration trackingConfiguration)	Asynchronously reads the next available MessageBatch for a given tracker.
CompletableFuture<MessageBatch>	WebsocketTrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration configuration)

Methods in io.fluxzero.sdk.tracking.client with parameters of type MessageBatch

Modifier and Type	Method	Description
protected void	DefaultTracker.process(MessageBatch batch)

Uses of MessageBatch in io.fluxzero.sdk.tracking.metrics

Methods in io.fluxzero.sdk.tracking.metrics that return types with arguments of type MessageBatch

Modifier and Type	Method	Description
Consumer<MessageBatch>	DisableMetrics.intercept(Consumer<MessageBatch> consumer, Tracker tracker)
Consumer<MessageBatch>	TrackerMonitor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)

Method parameters in io.fluxzero.sdk.tracking.metrics with type arguments of type MessageBatch

Modifier and Type	Method	Description
Consumer<MessageBatch>	DisableMetrics.intercept(Consumer<MessageBatch> consumer, Tracker tracker)
Consumer<MessageBatch>	TrackerMonitor.intercept(Consumer<MessageBatch> consumer, Tracker tracker)