com.hazelcast.monitor.impl

Class LocalWanPublisherStatsImpl

java.lang.Object

com.hazelcast.monitor.impl.LocalWanPublisherStatsImpl

All Implemented Interfaces:

JsonSerializable, LocalWanPublisherStats

public class LocalWanPublisherStatsImpl
extends Object
implements LocalWanPublisherStats

Constructor Summary

Constructors

Constructor and Description
LocalWanPublisherStatsImpl()

Method Summary

Modifier and Type	Method and Description
void	fromJson(com.eclipsesource.json.JsonObject json)
int	getOutboundQueueSize() Returns the outbound queue size on this member
Map<String,WanEventCounter.EventCounter>	getSentCacheEventCounter() Returns the counter for the successfully transfered cache WAN events.
Map<String,WanEventCounter.EventCounter>	getSentMapEventCounter() Returns the counter for the successfully transfered map WAN events.
long	getTotalPublishedEventCount() Returns the total number of published events from this member
long	getTotalPublishLatency() Returns the total latency of published wan events from this member by millisecond.
void	incrementPublishedEventCount(long latency)
boolean	isConnected() Returns if this member is connected to the Wan publisher
boolean	isPaused() Returns if the wan replication on this member is paused
void	setConnected(boolean connected)
void	setOutboundQueueSize(int outboundQueueSize)
void	setPaused(boolean paused)
void	setSentCacheEventCounter(Map<String,WanEventCounter.EventCounter> sentCacheEventCounter)
void	setSentMapEventCounter(Map<String,WanEventCounter.EventCounter> sentMapEventCounter)
com.eclipsesource.json.JsonObject	toJson()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalWanPublisherStatsImpl

public LocalWanPublisherStatsImpl()

Method Detail

isConnected

public boolean isConnected()

Description copied from interface: LocalWanPublisherStats

Returns if this member is connected to the Wan publisher

Specified by:

isConnected in interface LocalWanPublisherStats

Returns:

if this member is connected to the Wan publisher

setConnected

public void setConnected(boolean connected)

getOutboundQueueSize

public int getOutboundQueueSize()

Description copied from interface: LocalWanPublisherStats

Returns the outbound queue size on this member

Specified by:

getOutboundQueueSize in interface LocalWanPublisherStats

Returns:

outbound queue size on this member

setOutboundQueueSize

public void setOutboundQueueSize(int outboundQueueSize)

isPaused

public boolean isPaused()

Description copied from interface: LocalWanPublisherStats

Returns if the wan replication on this member is paused

Specified by:

isPaused in interface LocalWanPublisherStats

Returns:

true the wan replication on this member is paused

setPaused

public void setPaused(boolean paused)

getTotalPublishLatency

public long getTotalPublishLatency()

Description copied from interface: LocalWanPublisherStats

Returns the total latency of published wan events from this member by millisecond.

Specified by:

getTotalPublishLatency in interface LocalWanPublisherStats

Returns:

latency of outbound records from this member by millisecond.

getTotalPublishedEventCount

public long getTotalPublishedEventCount()

Description copied from interface: LocalWanPublisherStats

Returns the total number of published events from this member

Specified by:

getTotalPublishedEventCount in interface LocalWanPublisherStats

Returns:

number of total published events from this member

getSentMapEventCounter

public Map<String,WanEventCounter.EventCounter> getSentMapEventCounter()

Description copied from interface: LocalWanPublisherStats

Returns the counter for the successfully transfered map WAN events.

Specified by:

getSentMapEventCounter in interface LocalWanPublisherStats

getSentCacheEventCounter

public Map<String,WanEventCounter.EventCounter> getSentCacheEventCounter()

Description copied from interface: LocalWanPublisherStats

Returns the counter for the successfully transfered cache WAN events.

Specified by:

getSentCacheEventCounter in interface LocalWanPublisherStats

setSentMapEventCounter

public void setSentMapEventCounter(Map<String,WanEventCounter.EventCounter> sentMapEventCounter)

setSentCacheEventCounter

public void setSentCacheEventCounter(Map<String,WanEventCounter.EventCounter> sentCacheEventCounter)

incrementPublishedEventCount

public void incrementPublishedEventCount(long latency)

toJson

public com.eclipsesource.json.JsonObject toJson()

Specified by:

toJson in interface JsonSerializable

fromJson

public void fromJson(com.eclipsesource.json.JsonObject json)

Specified by:

fromJson in interface JsonSerializable

toString

public String toString()

Overrides:

toString in class Object