Class AmqpAdapterMetrics

java.lang.Object

io.nosqlbench.adapter.amqp.util.AmqpAdapterMetrics

public class AmqpAdapterMetrics
extends Object

Constructor Summary

Constructors

Constructor	Description
AmqpAdapterMetrics(AmqpBaseOpDispenser amqpBaseOpDispenser, NBLabeledElement labeledParent)

Method Summary

Modifier and Type	Method	Description
com.codahale.metrics.Timer	getBindTimer()
com.codahale.metrics.Histogram	getE2eMsgProcLatencyHistogram()
com.codahale.metrics.Timer	getExecuteTimer()
com.codahale.metrics.Histogram	getMessagesizeHistogram()
com.codahale.metrics.Counter	getMsgErrDuplicateCounter()
com.codahale.metrics.Counter	getMsgErrLossCounter()
com.codahale.metrics.Counter	getMsgErrOutOfSeqCounter()
void	initS4JAdapterInstrumentation()
void	setMsgErrDuplicateCounter(com.codahale.metrics.Counter msgErrDuplicateCounter)
void	setMsgErrLossCounter(com.codahale.metrics.Counter msgErrLossCounter)
void	setMsgErrOutOfSeqCounter(com.codahale.metrics.Counter msgErrOutOfSeqCounter)

Methods inherited from class java.lang.Object

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

Constructor Details

AmqpAdapterMetrics

public AmqpAdapterMetrics(AmqpBaseOpDispenser amqpBaseOpDispenser,
 NBLabeledElement labeledParent)

Method Details

getE2eMsgProcLatencyHistogram

public com.codahale.metrics.Histogram getE2eMsgProcLatencyHistogram()

initS4JAdapterInstrumentation

public void initS4JAdapterInstrumentation()

getBindTimer

public com.codahale.metrics.Timer getBindTimer()

getExecuteTimer

public com.codahale.metrics.Timer getExecuteTimer()

getMessagesizeHistogram

public com.codahale.metrics.Histogram getMessagesizeHistogram()

getMsgErrOutOfSeqCounter

public com.codahale.metrics.Counter getMsgErrOutOfSeqCounter()

setMsgErrOutOfSeqCounter

public void setMsgErrOutOfSeqCounter(com.codahale.metrics.Counter msgErrOutOfSeqCounter)

getMsgErrLossCounter

public com.codahale.metrics.Counter getMsgErrLossCounter()

setMsgErrLossCounter

public void setMsgErrLossCounter(com.codahale.metrics.Counter msgErrLossCounter)

getMsgErrDuplicateCounter

public com.codahale.metrics.Counter getMsgErrDuplicateCounter()

setMsgErrDuplicateCounter

public void setMsgErrDuplicateCounter(com.codahale.metrics.Counter msgErrDuplicateCounter)