com.neeve.aep

Interface IAepBusConnectionStats

All Superinterfaces:

IStats

All Known Implementing Classes:

AepBusConnectionStats

public interface IAepBusConnectionStats
extends IStats

Defines the AEP bus connection's statistics interface.

Nested Class Summary

Nested classes/interfaces inherited from interface com.neeve.stats.IStats

IStats.Counter, IStats.Gauge, IStats.Latencies, IStats.Record, IStats.Records, IStats.Series

Method Summary

Modifier and Type	Method and Description
AepBusConnection	getBusConnection() Get the bus connection
int	getDisruptorCapacity() Get disruptor capacity (applicable only if operating in detached mode)
String	getDisruptorClaimStrategy() Get disruptor claim strategy (applicable only if operating in detached mode)
IStats.Latencies	getDisruptorOfferToPollLatencies() Gets the bus connection's offer to poll latencies.
int	getDisruptorRemaining() Get disruptor remaining (applicable only if operating in detached mode)
String	getDisruptorWaitStrategy() Get disruptor wait strategy (applicable only if operating in detached mode)
MessageLatencyManager	getLatencyManager() Get a binding's message latency connection.
long	getNumAcksSent() Get the number of messages acked by the bus binding.
int	getNumBindingFailures() Get the number of binding failures experienced by a bus connection
int	getNumChannelsUp() Get the number of "channel up" events received by a bus connection
int	getNumClients() Get the number of "clients" that a bus connection has
long	getNumCommits() Get the number of send transactions committed by a bus connection
long	getNumMsgBatchesRcvd() Get the number of message batches received by a bus connection
long	getNumMsgsEnqueued() Get the number of message enqueued for transmission to a bus connection
long	getNumMsgsInBatchesRcvd() Get the total number of message received by a bus connection in message batches
long	getNumMsgsRcvd() Get the number of message received by a bus connection
long	getNumMsgsSent() Get the number of messages transmitted by a bus connection
long	getNumPacketsRcvd() Get the number of packets (from direct clients) received by a bus connection
long	getNumPartialRollbacks() Get the number of partial (savepoint) send transactions rolled back by a bus connection
long	getNumRollbacks() Get the number of send transactions rolled back by a bus connection
long	getNumStabilityBatchesRcvd() Get the number of stability (ack) batch events received by a bus connection
long	getNumStabilityInBatchesRcvd() Get the number of stability (ack) events received in batches by a bus connection
long	getNumStabilityRcvd() Get the number of stability (ack) events received by a bus connection
boolean	isDetachedCommit() Is the bus connection operating in detached commit mode?

Methods inherited from interface com.neeve.stats.IStats

close, get, getLogger, getName, getType, startPeriodicOutput, stopPeriodicOutput

Method Detail

getBusConnection

AepBusConnection getBusConnection()

Get the bus connection

getNumMsgsRcvd

long getNumMsgsRcvd()

Get the number of message received by a bus connection

getNumMsgsInBatchesRcvd

long getNumMsgsInBatchesRcvd()

Get the total number of message received by a bus connection in message batches

getNumMsgBatchesRcvd

long getNumMsgBatchesRcvd()

Get the number of message batches received by a bus connection

getNumAcksSent

long getNumAcksSent()

Get the number of messages acked by the bus binding.

This counter does not necessarily reflect the number of acknowledgements that have been flushed to the wire.

getNumMsgsEnqueued

long getNumMsgsEnqueued()

Get the number of message enqueued for transmission to a bus connection

getNumMsgsSent

long getNumMsgsSent()

Get the number of messages transmitted by a bus connection

getNumStabilityRcvd

long getNumStabilityRcvd()

Get the number of stability (ack) events received by a bus connection

getNumStabilityInBatchesRcvd

long getNumStabilityInBatchesRcvd()

Get the number of stability (ack) events received in batches by a bus connection

getNumStabilityBatchesRcvd

long getNumStabilityBatchesRcvd()

Get the number of stability (ack) batch events received by a bus connection

getNumPacketsRcvd

long getNumPacketsRcvd()

Get the number of packets (from direct clients) received by a bus connection

getNumCommits

long getNumCommits()

Get the number of send transactions committed by a bus connection

getNumRollbacks

long getNumRollbacks()

Get the number of send transactions rolled back by a bus connection

getNumPartialRollbacks

long getNumPartialRollbacks()

Get the number of partial (savepoint) send transactions rolled back by a bus connection

getNumClients

int getNumClients()

Get the number of "clients" that a bus connection has

getNumChannelsUp

int getNumChannelsUp()

Get the number of "channel up" events received by a bus connection

getNumBindingFailures

int getNumBindingFailures()

Get the number of binding failures experienced by a bus connection

isDetachedCommit

boolean isDetachedCommit()

Is the bus connection operating in detached commit mode?

getDisruptorCapacity

int getDisruptorCapacity()

Get disruptor capacity (applicable only if operating in detached mode)

getDisruptorRemaining

int getDisruptorRemaining()

Get disruptor remaining (applicable only if operating in detached mode)

getDisruptorClaimStrategy

String getDisruptorClaimStrategy()

Get disruptor claim strategy (applicable only if operating in detached mode)

getDisruptorWaitStrategy

String getDisruptorWaitStrategy()

Get disruptor wait strategy (applicable only if operating in detached mode)

getDisruptorOfferToPollLatencies

IStats.Latencies getDisruptorOfferToPollLatencies()

Gets the bus connection's offer to poll latencies.

For a bus connection that is operating in detached mode, the latencies track the amount of time messages are latent in the disruptor queue.

Returns:

The bus connection's offer to poll latencies.

getLatencyManager

MessageLatencyManager getLatencyManager()

Get a binding's message latency connection.

Threading:

This method is safe for concurrent access by multiple threads.

This method returns the latency connection associated with a bus connection's binding. Since bindings can be lost and restablished during the life of a bus connection, the caller should check for null which is returned if the bus connection is currently offline.