public class DefaultMessageChannelMetrics extends AbstractMessageChannelMetrics
Modifier and Type | Class and Description |
---|---|
protected static class |
DefaultMessageChannelMetrics.DefaultChannelMetricsContext |
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MOVING_AVERAGE_WINDOW |
static long |
ONE_MINUTE_SECONDS |
static long |
ONE_SECOND_SECONDS |
protected AtomicLong |
receiveCount |
protected AtomicLong |
receiveErrorCount |
protected AtomicLong |
sendCount |
protected ExponentialMovingAverage |
sendDuration |
protected AtomicLong |
sendErrorCount |
protected ExponentialMovingAverageRate |
sendErrorRate |
protected ExponentialMovingAverageRate |
sendRate |
protected ExponentialMovingAverageRatio |
sendSuccessRatio |
logger, name
Constructor and Description |
---|
DefaultMessageChannelMetrics() |
DefaultMessageChannelMetrics(String name)
Construct an instance with default metrics with
window=10, period=1 second,
lapsePeriod=1 minute . |
DefaultMessageChannelMetrics(String name,
ExponentialMovingAverage sendDuration,
ExponentialMovingAverageRate sendErrorRate,
ExponentialMovingAverageRatio sendSuccessRatio,
ExponentialMovingAverageRate sendRate)
Construct an instance with the supplied metrics.
|
Modifier and Type | Method and Description |
---|---|
void |
afterError() |
void |
afterReceive() |
void |
afterSend(MetricsContext context,
boolean result)
End a send event.
|
MetricsContext |
beforeSend()
Begin a send event.
|
void |
destroy() |
Statistics |
getErrorRate() |
double |
getMaxSendDuration() |
double |
getMeanErrorRate() |
double |
getMeanErrorRatio() |
double |
getMeanSendDuration() |
double |
getMeanSendRate() |
double |
getMinSendDuration() |
int |
getReceiveCount() |
long |
getReceiveCountLong() |
int |
getReceiveErrorCount() |
long |
getReceiveErrorCountLong() |
int |
getSendCount() |
long |
getSendCountLong() |
Statistics |
getSendDuration() |
int |
getSendErrorCount() |
long |
getSendErrorCountLong() |
Statistics |
getSendRate() |
double |
getStandardDeviationSendDuration() |
double |
getTimeSinceLastSend() |
void |
reset()
Reset all counters/statistics.
|
String |
toString() |
isFullStatsEnabled, setFullStatsEnabled
public static final long ONE_SECOND_SECONDS
public static final long ONE_MINUTE_SECONDS
public static final int DEFAULT_MOVING_AVERAGE_WINDOW
protected final ExponentialMovingAverage sendDuration
protected final ExponentialMovingAverageRate sendErrorRate
protected final ExponentialMovingAverageRatio sendSuccessRatio
protected final ExponentialMovingAverageRate sendRate
protected final AtomicLong sendCount
protected final AtomicLong sendErrorCount
protected final AtomicLong receiveCount
protected final AtomicLong receiveErrorCount
public DefaultMessageChannelMetrics()
public DefaultMessageChannelMetrics(String name)
window=10, period=1 second,
lapsePeriod=1 minute
.name
- the name.public DefaultMessageChannelMetrics(String name, ExponentialMovingAverage sendDuration, ExponentialMovingAverageRate sendErrorRate, ExponentialMovingAverageRatio sendSuccessRatio, ExponentialMovingAverageRate sendRate)
factor=1000000.
and the the other arguments
must be created with the millis
constructor argument set to true.name
- the name.sendDuration
- an ExponentialMovingAverage
for calculating the send duration.sendErrorRate
- an ExponentialMovingAverageRate
for calculating the send error rate.sendSuccessRatio
- an ExponentialMovingAverageRatio
for calculating the success ratio.sendRate
- an ExponentialMovingAverageRate
for calculating the send rate.public void destroy()
public MetricsContext beforeSend()
AbstractMessageChannelMetrics
beforeSend
in class AbstractMessageChannelMetrics
AbstractMessageChannelMetrics.afterSend(MetricsContext, boolean)
call.public void afterSend(MetricsContext context, boolean result)
AbstractMessageChannelMetrics
AbstractMessageChannelMetrics.beforeSend()
call.afterSend
in class AbstractMessageChannelMetrics
context
- the context.result
- true for success, false otherwise.public void reset()
AbstractMessageChannelMetrics
reset
in class AbstractMessageChannelMetrics
public int getSendCount()
getSendCount
in class AbstractMessageChannelMetrics
public long getSendCountLong()
getSendCountLong
in class AbstractMessageChannelMetrics
public int getSendErrorCount()
getSendErrorCount
in class AbstractMessageChannelMetrics
public long getSendErrorCountLong()
getSendErrorCountLong
in class AbstractMessageChannelMetrics
public double getTimeSinceLastSend()
getTimeSinceLastSend
in class AbstractMessageChannelMetrics
public double getMeanSendRate()
getMeanSendRate
in class AbstractMessageChannelMetrics
public double getMeanErrorRate()
getMeanErrorRate
in class AbstractMessageChannelMetrics
public double getMeanErrorRatio()
getMeanErrorRatio
in class AbstractMessageChannelMetrics
public double getMeanSendDuration()
getMeanSendDuration
in class AbstractMessageChannelMetrics
public double getMinSendDuration()
getMinSendDuration
in class AbstractMessageChannelMetrics
public double getMaxSendDuration()
getMaxSendDuration
in class AbstractMessageChannelMetrics
public double getStandardDeviationSendDuration()
getStandardDeviationSendDuration
in class AbstractMessageChannelMetrics
public Statistics getSendDuration()
getSendDuration
in class AbstractMessageChannelMetrics
public Statistics getSendRate()
getSendRate
in class AbstractMessageChannelMetrics
public Statistics getErrorRate()
getErrorRate
in class AbstractMessageChannelMetrics
public void afterReceive()
afterReceive
in class AbstractMessageChannelMetrics
public void afterError()
afterError
in class AbstractMessageChannelMetrics
public int getReceiveCount()
getReceiveCount
in class AbstractMessageChannelMetrics
public long getReceiveCountLong()
getReceiveCountLong
in class AbstractMessageChannelMetrics
public int getReceiveErrorCount()
getReceiveErrorCount
in class AbstractMessageChannelMetrics
public long getReceiveErrorCountLong()
getReceiveErrorCountLong
in class AbstractMessageChannelMetrics