com.neeve.aep
Interface IAepEngineStats

All Superinterfaces:

com.neeve.stats.IStats

public interface IAepEngineStats
extends com.neeve.stats.IStats

Defines the AEP engine's statistics interface.

Nested Class Summary

static interface

IAepEngineStats.IMessageTypeStats Exports message type specific statistics

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

com.neeve.stats.IStats.Counter, com.neeve.stats.IStats.Gauge, com.neeve.stats.IStats.Latencies

Method Summary

void	clearNumCommitsOutstandingAlertThreshold() Clear the outstanding transaction commit alert threshold.
int	getBackupOutboundLogQueueSize() Get the backup outbound log queue size
int	getBackupOutboundQueueSize() Get the backup outbound queue size
List<IAepBusManagerStats>	getBusManagerStats() Get the bus manager stats.
void	getBusManagerStats(List<IAepBusManagerStats> busManagerStats) Allows collection of IAepBusManagerStats without producing garbage.
com.neeve.stats.IStats.Latencies	getCommitEpilogueLatencies() Get the commit epilogue latencies
com.neeve.stats.IStats.Latencies	getCommitFullLatencies() Get the commit full latencies
com.neeve.stats.IStats.Latencies	getCommitPrologueLatencies() Get the commit prologue latencies
com.neeve.stats.IStats.Latencies	getCommitSendLatencies() Get the commit send latencies
com.neeve.stats.IStats.Latencies	getCommitStartLatencies() Get the commit start latencies
com.neeve.stats.IStats.Latencies	getCommitStoreLatencies() Get the store commit latencies
com.neeve.event.IEventMultiplexerStats	getEventMultiplexerStats() Get the event multiplexer stats.
com.neeve.stats.IStats.Latencies	getInAckLatencies() Get the in-ack latencies
com.neeve.stats.IStats.Latencies	getInOutLatencies() Get the in-out latencies
cern.colt.map.OpenIntObjectHashMap	getMessageTypeStatsTable() Get the message type specific stats table Note: The table needs to be locked when traversing or looking up entries.
com.neeve.stats.IStats.Latencies	getMsgPreProcessingLatencies() Get the message pre-processing latencies
com.neeve.stats.IStats.Latencies	getMsgProcessingLatencies() Get the message processing latencies
com.neeve.stats.IStats.Latencies	getMsgSendCoreLatencies() Get the message send core latencies
com.neeve.stats.IStats.Latencies	getMsgSendLatencies() Get the message send latencies
long	getNumCommitsCompleted() Get the number of application transaction commits completed
long	getNumCommitsStarted() Get the number of application transaction commits started
long	getNumDupMsgsRcvd() Get the number of duplicate messages received.
long	getNumEventsRcvd() Get the total number of events (messages + others) received.
long	getNumFlowEventsProcComplete() Get the number of flow events (events tagged to a flow) whose processing has completed (acked)
long	getNumFlowEventsProcFail() Get the number of flow events (events tagged to a flow) failed processing
long	getNumFlowEventsProcSuccess() Get the number of flow events (events tagged to a flow) successfully processed
long	getNumFlowEventsRcvd() Get the number of flow events (events tagged to a flow) received.
int	getNumFlows() Get the number of flows being processed.
long	getNumMsgsRcvdBestEffort() Get the number of best-effort messages received.
long	getNumMsgsRcvdGuaranteed() Get the number of guaranteed messages received.
long	getNumMsgsResent() Get the number of messages resent.
long	getNumMsgsSentBestEffort() Get the number of best-effort messages sent.
long	getNumMsgsSentGuaranteed() Get the number of guaranteed messages sent.
long	getNumMsgsSourced() Get the number of messages sourced.
long	getNumRollbacks() Get the number of transaction rollbacks
long	getNumSendCommitsCompleted() Get the number of application send commits completed
long	getNumSendCommitsStarted() Get the number of application send commits started
long	getNumStoreCommitsCompleted() Get the number of application store commits completed
long	getNumStoreCommitsStarted() Get the number of application store commits started
long	getNumTransactions() Get the number of application transactions
long	getOutboundSequenceNumber() Get the current outbound sequence number
long	getOutboundStableSequenceNumber() Get the current outbound stable sequence number
int	getSendCommitCompletionQueueSize() Get the current send commit completion quue size
com.neeve.stats.IStats.Latencies	getSendCommitLatencies() Deprecated.
IStoreBindingStats	getStoreBindingStats() Get the engine store binding stats.
int	getStoreCommitCompletionQueueSize() Get the current store commit completion quue size
com.neeve.stats.IStats.Latencies	getStoreCommitLatencies() Deprecated.
IStoreBindingStats	getStoreStats() Deprecated.
com.neeve.stats.IStats.Latencies	getTransactionLeg1ProcessingTimes() Get the processing times of the first leg of transaction execution
com.neeve.stats.IStats.Latencies	getTransactionLeg2ProcessingTimes() Get the processing times of the second leg of transaction execution
com.neeve.stats.IStats.Latencies	getTransactionLeg3ProcessingTimes() Get the processing times of the third leg of transaction execution
List<? extends com.neeve.stats.IStats.Counter>	getUserCounterStats() Gets user registered IStats.Counter stats.
List<? extends com.neeve.stats.IStats.Gauge>	getUserGaugeStats() Gets user registered IStats.Gauge stats.
List<? extends com.neeve.stats.IStats.Latencies>	getUserLatencyStats() Gets user registered latency stats.
void	setNumCommitsOutstandingAlertThreshold(long threshold) Set the outstanding transaction commit alert threshold.

Methods inherited from interface com.neeve.stats.IStats

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

Method Detail

getNumFlows

int getNumFlows()

Get the number of flows being processed.

getNumMsgsRcvdBestEffort

long getNumMsgsRcvdBestEffort()

Get the number of best-effort messages received.

getNumMsgsRcvdGuaranteed

long getNumMsgsRcvdGuaranteed()

Get the number of guaranteed messages received.

getNumMsgsSourced

long getNumMsgsSourced()

Get the number of messages sourced.

Sourced messages apply only to event sourcing. This counter includes messages replicated to the backup, initialized from the event log at the primary or initialized from the primary at the backup.

getNumDupMsgsRcvd

long getNumDupMsgsRcvd()

Get the number of duplicate messages received.

getNumMsgsSentBestEffort

long getNumMsgsSentBestEffort()

Get the number of best-effort messages sent.

getNumMsgsSentGuaranteed

long getNumMsgsSentGuaranteed()

Get the number of guaranteed messages sent.

getNumMsgsResent

long getNumMsgsResent()

Get the number of messages resent.

getNumEventsRcvd

long getNumEventsRcvd()

Get the total number of events (messages + others) received.

getNumFlowEventsRcvd

long getNumFlowEventsRcvd()

Get the number of flow events (events tagged to a flow) received.

getNumFlowEventsProcSuccess

long getNumFlowEventsProcSuccess()

Get the number of flow events (events tagged to a flow) successfully processed

getNumFlowEventsProcFail

long getNumFlowEventsProcFail()

Get the number of flow events (events tagged to a flow) failed processing

getNumFlowEventsProcComplete

long getNumFlowEventsProcComplete()

Get the number of flow events (events tagged to a flow) whose processing has completed (acked)

getNumTransactions

long getNumTransactions()

Get the number of application transactions

getNumCommitsStarted

long getNumCommitsStarted()

Get the number of application transaction commits started

getNumCommitsCompleted

long getNumCommitsCompleted()

Get the number of application transaction commits completed

setNumCommitsOutstandingAlertThreshold

void setNumCommitsOutstandingAlertThreshold(long threshold)

Set the outstanding transaction commit alert threshold.

This method sets an alert on the number of outstanding transaction commits. The application will receive an AepStatsAlertEvent with an alert type of AboveThreshold when the number of outstanding transaction commits exceeds the set threshold and periodically thereafter as long as the number of outstanding transaction commits remains above the threshold. The alerts will terminate with an alert type Abated and resume subsequently once the number of outstanding commits crosses the threshold again.

Alert events for this metric are received with a metric name of "numCommitsOutstanding"

clearNumCommitsOutstandingAlertThreshold

void clearNumCommitsOutstandingAlertThreshold()

Clear the outstanding transaction commit alert threshold.

This method clears the application transaction commit alert threshold. No alerts related to the number of outstanding transaction commits are dispatched subsequent to this call.

getNumSendCommitsStarted

long getNumSendCommitsStarted()

Get the number of application send commits started

getNumSendCommitsCompleted

long getNumSendCommitsCompleted()

Get the number of application send commits completed

getSendCommitCompletionQueueSize

int getSendCommitCompletionQueueSize()

Get the current send commit completion quue size

getNumStoreCommitsStarted

long getNumStoreCommitsStarted()

Get the number of application store commits started

getStoreCommitCompletionQueueSize

int getStoreCommitCompletionQueueSize()

Get the current store commit completion quue size

getNumStoreCommitsCompleted

long getNumStoreCommitsCompleted()

Get the number of application store commits completed

getNumRollbacks

long getNumRollbacks()

Get the number of transaction rollbacks

getBackupOutboundQueueSize

int getBackupOutboundQueueSize()

Get the backup outbound queue size

getBackupOutboundLogQueueSize

int getBackupOutboundLogQueueSize()

Get the backup outbound log queue size

getOutboundSequenceNumber

long getOutboundSequenceNumber()

Get the current outbound sequence number

getOutboundStableSequenceNumber

long getOutboundStableSequenceNumber()

Get the current outbound stable sequence number

getMessageTypeStatsTable

cern.colt.map.OpenIntObjectHashMap getMessageTypeStatsTable()

Get the message type specific stats table Note: The table needs to be locked when traversing or looking up entries.

getMsgPreProcessingLatencies

com.neeve.stats.IStats.Latencies getMsgPreProcessingLatencies()

Get the message pre-processing latencies

getMsgProcessingLatencies

com.neeve.stats.IStats.Latencies getMsgProcessingLatencies()

Get the message processing latencies

getMsgSendLatencies

com.neeve.stats.IStats.Latencies getMsgSendLatencies()

Get the message send latencies

getMsgSendCoreLatencies

com.neeve.stats.IStats.Latencies getMsgSendCoreLatencies()

Get the message send core latencies

getCommitStartLatencies

com.neeve.stats.IStats.Latencies getCommitStartLatencies()

Get the commit start latencies

getCommitPrologueLatencies

com.neeve.stats.IStats.Latencies getCommitPrologueLatencies()

Get the commit prologue latencies

getCommitSendLatencies

com.neeve.stats.IStats.Latencies getCommitSendLatencies()

Get the commit send latencies

getSendCommitLatencies

@Deprecated
com.neeve.stats.IStats.Latencies getSendCommitLatencies()

Deprecated.

Same as getCommitSendLatencies()

getCommitStoreLatencies

com.neeve.stats.IStats.Latencies getCommitStoreLatencies()

Get the store commit latencies

getStoreCommitLatencies

@Deprecated
com.neeve.stats.IStats.Latencies getStoreCommitLatencies()

Deprecated.

Same as getCommitStoreLatencies()

getCommitEpilogueLatencies

com.neeve.stats.IStats.Latencies getCommitEpilogueLatencies()

Get the commit epilogue latencies

getCommitFullLatencies

com.neeve.stats.IStats.Latencies getCommitFullLatencies()

Get the commit full latencies

getInOutLatencies

com.neeve.stats.IStats.Latencies getInOutLatencies()

Get the in-out latencies

getInAckLatencies

com.neeve.stats.IStats.Latencies getInAckLatencies()

Get the in-ack latencies

getTransactionLeg1ProcessingTimes

com.neeve.stats.IStats.Latencies getTransactionLeg1ProcessingTimes()

Get the processing times of the first leg of transaction execution

getTransactionLeg2ProcessingTimes

com.neeve.stats.IStats.Latencies getTransactionLeg2ProcessingTimes()

Get the processing times of the second leg of transaction execution

getTransactionLeg3ProcessingTimes

com.neeve.stats.IStats.Latencies getTransactionLeg3ProcessingTimes()

Get the processing times of the third leg of transaction execution

getBusManagerStats

List<IAepBusManagerStats> getBusManagerStats()

Get the bus manager stats.

This method returns a list of bus manager statistics objects, one for each bus binding managed by the engine.

getBusManagerStats

void getBusManagerStats(List<IAepBusManagerStats> busManagerStats)

Allows collection of IAepBusManagerStats without producing garbage.

Parameters:

busManagerStats - The target list into which bus manager stats are added.

getUserLatencyStats

List<? extends com.neeve.stats.IStats.Latencies> getUserLatencyStats()

Gets user registered latency stats. The user stats are registered by the engine prior to engine start.

This method returns a list of user registered latency stats. The returned list may not be modified by the caller, and is safe for access by multiple threads.

getUserCounterStats

List<? extends com.neeve.stats.IStats.Counter> getUserCounterStats()

Gets user registered IStats.Counter stats. The user stats are registered by the engine prior to engine start.d

This method returns a list of user registered IStats.Counter stats. The returned list may not be modified by the caller, and is safe for access by multiple threads.

getUserGaugeStats

List<? extends com.neeve.stats.IStats.Gauge> getUserGaugeStats()

Gets user registered IStats.Gauge stats. The user stats are registered by the engine prior to engine start.

This method returns a list of user registered IStats.Gauge stats. The returned list may not be modified by the caller, and is safe for access by multiple threads.

getStoreStats

@Deprecated
IStoreBindingStats getStoreStats()

Deprecated.

Get the engine store stats.

d THIS METHOD HAS BEEN DEPRECATED. PLEASE USE getStoreBindingStats()

Returns:

Returns the store stats. A value of null if returned for engines without a store.

getStoreBindingStats

IStoreBindingStats getStoreBindingStats()

Get the engine store binding stats.

Returns:

Returns the store stats. A value of null if returned for engines without a store.

getEventMultiplexerStats

com.neeve.event.IEventMultiplexerStats getEventMultiplexerStats()

Get the event multiplexer stats.