Class OpTimeTrackAmqpMsgRecvOp

java.lang.Object

io.nosqlbench.adapter.amqp.ops.AmqpTimeTrackOp

io.nosqlbench.adapter.amqp.ops.OpTimeTrackAmqpMsgRecvOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

public class OpTimeTrackAmqpMsgRecvOp
extends AmqpTimeTrackOp

Field Summary

Fields inherited from class io.nosqlbench.adapter.amqp.ops.AmqpTimeTrackOp

activityStartTime, amqpSpace, channel, cycleObj, exchangeName, maxOpTimeInSec

Constructor Summary

Constructors

Constructor	Description
OpTimeTrackAmqpMsgRecvOp(AmqpAdapterMetrics amqpAdapterMetrics, AmqpSpace amqpSpace, com.rabbitmq.client.Channel channel, String exchangeName, String queueName)

Method Summary

Methods inherited from class io.nosqlbench.adapter.amqp.ops.AmqpTimeTrackOp

apply

Methods inherited from class java.lang.Object

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

Constructor Details

OpTimeTrackAmqpMsgRecvOp

public OpTimeTrackAmqpMsgRecvOp(AmqpAdapterMetrics amqpAdapterMetrics,
 AmqpSpace amqpSpace,
 com.rabbitmq.client.Channel channel,
 String exchangeName,
 String queueName)