Uses of Class
io.nosqlbench.adapters.api.metrics.ReceivedMessageSequenceTracker

Packages that use ReceivedMessageSequenceTracker

Package	Description
io.nosqlbench.adapter.kafka.ops
io.nosqlbench.adapter.pulsar.ops

Uses of ReceivedMessageSequenceTracker in io.nosqlbench.adapter.kafka.ops

Constructor parameters in io.nosqlbench.adapter.kafka.ops with type arguments of type ReceivedMessageSequenceTracker

Modifier	Constructor	Description
	OpTimeTrackKafkaConsumer(KafkaSpace kafkaSpace, boolean asyncMsgCommit, int msgPoolIntervalInMs, boolean autoCommitEnabled, int maxMsgCntPerCommit, org.apache.kafka.clients.consumer.KafkaConsumer<String,String> consumer, KafkaAdapterMetrics kafkaAdapterMetrics, EndToEndStartingTimeSource e2eStartingTimeSrc, Function<String,ReceivedMessageSequenceTracker> receivedMessageSequenceTrackerForTopic, boolean seqTracking)

Uses of ReceivedMessageSequenceTracker in io.nosqlbench.adapter.pulsar.ops

Constructor parameters in io.nosqlbench.adapter.pulsar.ops with type arguments of type ReceivedMessageSequenceTracker

Modifier	Constructor	Description
	MessageConsumerOp(PulsarAdapterMetrics pulsarAdapterMetrics, org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.client.api.Schema<?> pulsarSchema, boolean asyncApi, boolean useTransact, boolean seqTracking, Supplier<org.apache.pulsar.client.api.transaction.Transaction> transactSupplier, String payloadRttField, EndToEndStartingTimeSource e2eStartingTimeSrc, Function<String,ReceivedMessageSequenceTracker> receivedMessageSequenceTrackerForTopic, org.apache.pulsar.client.api.Consumer<?> consumer, int consumerTimeoutInSec)