com.neeve.aep
Interface IAepBusManagerStats

All Superinterfaces:

IStats

All Known Implementing Classes:

AepBusManagerStats

public interface IAepBusManagerStats
extends IStats

Defines the AEP bus manager's statistics interface.

Nested Class Summary

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

IStats.Counter, IStats.Gauge, IStats.Latencies, IStats.Series

Method Summary

AepBusManager	getBusManager() Get the bus manager
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 manager'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 manager.
long	getNumAcksSent() Get the number of messages acked by the bus binding.
long	getNumAsyncFlushCompletions() Get the number of async flush completions received by a bus manager
int	getNumBindingFailures() Get the number of binding failures experienced by a bus manager
int	getNumChannelsUp() Get the number of "channel up" events received by a bus manager
int	getNumClients() Get the number of "clients" that a bus manager has
long	getNumCommits() Get the number of send transactions committed by a bus manager
long	getNumFlushesAsync() Get the number of asynchronous binding flushes performed by a bus manager
long	getNumFlushesSync() Get the number of synchronous binding flushes performed by a bus manager
long	getNumMsgBatchesRcvd() Get the number of message batches received by a bus manager
long	getNumMsgsEnqueued() Get the number of message enqueued for transmission to a bus manager
long	getNumMsgsFlushedAsync() Get the number of messages flushed asynchronously by a bus manager
long	getNumMsgsFlushedSync() Get the number of messages flushed synchronously by a bus manager
long	getNumMsgsInBatchesRcvd() Get the total number of message received by a bus manager in message batches
long	getNumMsgsRcvd() Get the number of message received by a bus manager
long	getNumMsgsSent() Get the number of messages transmitted by a bus manager
long	getNumPacketsRcvd() Get the number of packets (from direct clients) received by a bus manager
long	getNumPartialRollbacks() Get the number of partial (savepoint) send transactions rolled back by a bus manager
long	getNumRollbacks() Get the number of send transactions rolled back by a bus manager
long	getNumStabilityBatchesRcvd() Get the number of stability (ack) batch events received by a bus manager
long	getNumStabilityInBatchesRcvd() Get the number of stability (ack) events received in batches by a bus manager
long	getNumStabilityRcvd() Get the number of stability (ack) events received by a bus manager
boolean	isDetachedCommit() Is the bus manager operating in detached commit mode?

Methods inherited from interface com.neeve.stats.IStats

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

Method Detail

getBusManager

AepBusManager getBusManager()

Get the bus manager

getNumMsgsRcvd

long getNumMsgsRcvd()

Get the number of message received by a bus manager

getNumMsgsInBatchesRcvd

long getNumMsgsInBatchesRcvd()

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

getNumMsgBatchesRcvd

long getNumMsgBatchesRcvd()

Get the number of message batches received by a bus manager

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 manager

getNumMsgsSent

long getNumMsgsSent()

Get the number of messages transmitted by a bus manager

getNumFlushesSync

long getNumFlushesSync()

Get the number of synchronous binding flushes performed by a bus manager

getNumMsgsFlushedSync

long getNumMsgsFlushedSync()

Get the number of messages flushed synchronously by a bus manager

getNumFlushesAsync

long getNumFlushesAsync()

Get the number of asynchronous binding flushes performed by a bus manager

getNumAsyncFlushCompletions

long getNumAsyncFlushCompletions()

Get the number of async flush completions received by a bus manager

getNumMsgsFlushedAsync

long getNumMsgsFlushedAsync()

Get the number of messages flushed asynchronously by a bus manager

getNumStabilityRcvd

long getNumStabilityRcvd()

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

getNumStabilityInBatchesRcvd

long getNumStabilityInBatchesRcvd()

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

getNumStabilityBatchesRcvd

long getNumStabilityBatchesRcvd()

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

getNumPacketsRcvd

long getNumPacketsRcvd()

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

getNumCommits

long getNumCommits()

Get the number of send transactions committed by a bus manager

getNumRollbacks

long getNumRollbacks()

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

getNumPartialRollbacks

long getNumPartialRollbacks()

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

getNumClients

int getNumClients()

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

getNumChannelsUp

int getNumChannelsUp()

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

getNumBindingFailures

int getNumBindingFailures()

Get the number of binding failures experienced by a bus manager

isDetachedCommit

boolean isDetachedCommit()

Is the bus manager 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 manager's offer to poll latencies.

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

Returns:

The bus manager's offer to poll latencies.

getLatencyManager

MessageLatencyManager getLatencyManager()

Get a binding's message latency manager.

Threading:

This method is safe for concurrent access by multiple threads.

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