Class MessageConsumerOp

java.lang.Object

io.nosqlbench.adapter.pulsar.ops.PulsarOp

io.nosqlbench.adapter.pulsar.ops.PulsarClientOp

io.nosqlbench.adapter.pulsar.ops.MessageConsumerOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

public class MessageConsumerOp
extends PulsarClientOp

Field Summary

Fields inherited from class io.nosqlbench.adapter.pulsar.ops.PulsarClientOp

e2eMsgProcLatencyHistogram, messageSizeHistogram, payloadRttHistogram, pulsarClient, pulsarSchema, transactionCommitTimer

Fields inherited from class io.nosqlbench.adapter.pulsar.ops.PulsarOp

asyncApi, pulsarAdapterMetrics

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method	Description
Object	apply(long value)	Run an action for the given cycle.

Methods inherited from class io.nosqlbench.adapter.pulsar.ops.PulsarClientOp

getAvroSchemaFromConfiguration, getKeyAvroSchemaFromConfiguration

Methods inherited from class java.lang.Object

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

Constructor Details

MessageConsumerOp

public 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)

Method Details

apply

public Object apply(long value)

Description copied from interface: CycleOp

Run an action for the given cycle.

Parameters:

value - The cycle value for which an operation is run