public class LocalWanPublisherStatsImpl extends Object implements LocalWanPublisherStats
Constructor and Description |
---|
LocalWanPublisherStatsImpl() |
Modifier and Type | Method and Description |
---|---|
void |
fromJson(com.eclipsesource.json.JsonObject json) |
int |
getOutboundQueueSize()
Returns the outbound queue size on this member
|
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) |
com.eclipsesource.json.JsonObject |
toJson() |
String |
toString() |
public boolean isConnected()
LocalWanPublisherStats
isConnected
in interface LocalWanPublisherStats
public void setConnected(boolean connected)
public int getOutboundQueueSize()
LocalWanPublisherStats
getOutboundQueueSize
in interface LocalWanPublisherStats
public void setOutboundQueueSize(int outboundQueueSize)
public boolean isPaused()
LocalWanPublisherStats
isPaused
in interface LocalWanPublisherStats
public void setPaused(boolean paused)
public long getTotalPublishLatency()
LocalWanPublisherStats
getTotalPublishLatency
in interface LocalWanPublisherStats
public long getTotalPublishedEventCount()
LocalWanPublisherStats
getTotalPublishedEventCount
in interface LocalWanPublisherStats
public void incrementPublishedEventCount(long latency)
public com.eclipsesource.json.JsonObject toJson()
toJson
in interface JsonSerializable
public void fromJson(com.eclipsesource.json.JsonObject json)
fromJson
in interface JsonSerializable
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.