Class OpTimeTrackAmqpMsgSendOp

java.lang.Object

io.nosqlbench.adapter.amqp.ops.AmqpTimeTrackOp

io.nosqlbench.adapter.amqp.ops.OpTimeTrackAmqpMsgSendOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

public class OpTimeTrackAmqpMsgSendOp
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
OpTimeTrackAmqpMsgSendOp(AmqpAdapterMetrics amqpAdapterMetrics, AmqpSpace amqpSpace, com.rabbitmq.client.Channel channel, String exchangeName, String message, String routingKey, boolean publishConfirm, String confirmMode, int confirmBatchNum)

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

OpTimeTrackAmqpMsgSendOp

public OpTimeTrackAmqpMsgSendOp(AmqpAdapterMetrics amqpAdapterMetrics,
 AmqpSpace amqpSpace,
 com.rabbitmq.client.Channel channel,
 String exchangeName,
 String message,
 String routingKey,
 boolean publishConfirm,
 String confirmMode,
 int confirmBatchNum)