Uses of Class
io.fluxcapacitor.common.api.tracking.MessageBatch
Packages that use MessageBatch
-
Uses of MessageBatch in io.fluxcapacitor.common.tracking
Methods in io.fluxcapacitor.common.tracking with parameters of type MessageBatchModifier and TypeMethodDescriptionvoidSimpleTracker.send(MessageBatch batch) voidTracker.send(MessageBatch batch) voidWebSocketTracker.send(MessageBatch batch) default voidTracker.sendEmptyBatch(MessageBatch batch) protected voidDefaultTrackingStrategy.waitForMessages(Tracker tracker, MessageBatch emptyBatch, PositionStore positionStore) protected voidDefaultTrackingStrategy.waitForUpdate(Tracker tracker, MessageBatch emptyBatch, Runnable followUp) Constructor parameters in io.fluxcapacitor.common.tracking with type arguments of type MessageBatchModifierConstructorDescriptionSimpleTracker(String consumerName, int maxSize, Consumer<MessageBatch> handler) WebSocketTracker(Read read, MessageType messageType, String clientId, String sessionId, Consumer<MessageBatch> handler)