Package org.gridgain.internal.dr.metrics

Class DrReceiverCacheMetricsMxBeanImpl

java.lang.Object

org.gridgain.internal.dr.metrics.DrReceiverCacheMetricsMxBeanImpl

All Implemented Interfaces:

DrBatchEventListener, DrReceiverCacheMetricsMxBean

public class DrReceiverCacheMetricsMxBeanImpl
extends Object
implements DrReceiverCacheMetricsMxBean, DrBatchEventListener

Single cache replication metrics.

Field Summary

Fields inherited from interface org.gridgain.internal.dr.metrics.DrBatchEventListener

NOOP_LISTENER

Method Summary

Modifier and Type	Method	Description
int	getBatchesAcked()
int	getBatchesFailed()
int	getBatchesReceived()
long	getBytesReceived()
long	getEntriesAcked()
long	getEntriesReceived()
long	getMessageQueueLength()
long	getMessageQueueSizeBytes()
void	onAcked(int entriesCnt)
void	onError()
void	onProcessed(long messageSize)
void	onReceived(int entriesCnt, int bytesCnt)

Methods inherited from class java.lang.Object

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

Method Details

getBatchesReceived

public int getBatchesReceived()

Specified by:

getBatchesReceived in interface DrReceiverCacheMetricsMxBean

getBatchesAcked

public int getBatchesAcked()

Specified by:

getBatchesAcked in interface DrReceiverCacheMetricsMxBean

getBatchesFailed

public int getBatchesFailed()

Specified by:

getBatchesFailed in interface DrReceiverCacheMetricsMxBean

getEntriesReceived

public long getEntriesReceived()

Specified by:

getEntriesReceived in interface DrReceiverCacheMetricsMxBean

getEntriesAcked

public long getEntriesAcked()

Specified by:

getEntriesAcked in interface DrReceiverCacheMetricsMxBean

getBytesReceived

public long getBytesReceived()

Specified by:

getBytesReceived in interface DrReceiverCacheMetricsMxBean

getMessageQueueSizeBytes

public long getMessageQueueSizeBytes()

Specified by:

getMessageQueueSizeBytes in interface DrReceiverCacheMetricsMxBean

getMessageQueueLength

public long getMessageQueueLength()

Specified by:

getMessageQueueLength in interface DrReceiverCacheMetricsMxBean

onReceived

public void onReceived(int entriesCnt,
 int bytesCnt)

Specified by:

onReceived in interface DrBatchEventListener

onProcessed

public void onProcessed(long messageSize)

Specified by:

onProcessed in interface DrBatchEventListener

onAcked

public void onAcked(int entriesCnt)

Specified by:

onAcked in interface DrBatchEventListener

onError

public void onError()

Specified by:

onError in interface DrBatchEventListener