Class AmqpTimeTrackOp

java.lang.Object

io.nosqlbench.adapter.amqp.ops.AmqpTimeTrackOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

Direct Known Subclasses:

OpTimeTrackAmqpMsgRecvOp, OpTimeTrackAmqpMsgSendOp

public abstract class AmqpTimeTrackOp
extends Object
implements CycleOp<Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	activityStartTime
protected final AmqpSpace	amqpSpace
protected final com.rabbitmq.client.Channel	channel
protected Object	cycleObj
protected final String	exchangeName
protected final long	maxOpTimeInSec

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

amqpSpace

protected final AmqpSpace amqpSpace

channel

protected final com.rabbitmq.client.Channel channel

exchangeName

protected final String exchangeName

maxOpTimeInSec

protected final long maxOpTimeInSec

activityStartTime

protected final long activityStartTime

cycleObj

protected Object cycleObj

Constructor Details

AmqpTimeTrackOp

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

Method Details

apply

public Object apply(long cycle)

Description copied from interface: CycleOp

Run an action for the given cycle.

Specified by:

apply in interface CycleOp<Object>

Specified by:

apply in interface LongFunction<Object>

Parameters:

cycle - The cycle value for which an operation is run