Package org.apache.activemq.artemis.utils.critical

Class CriticalComponentImpl

java.lang.Object

org.apache.activemq.artemis.utils.critical.CriticalComponentImpl

All Implemented Interfaces:

CriticalComponent

Direct Known Subclasses:

AbstractJournalStorageManager, QueueImpl, TimedBuffer

public class CriticalComponentImpl
extends Object
implements CriticalComponent

This is not abstract as it could be used through aggregations or extensions. This is only good for cases where you call leave within the same thread as you called enter.

Constructor Summary

Constructors

Constructor	Description
CriticalComponentImpl(CriticalAnalyzer analyzer, int numberOfPaths)

Method Summary

Modifier and Type	Method	Description
boolean	checkExpiration(long timeout, boolean reset)	Check if the component is expired at a given timeout..
CriticalAnalyzer	getCriticalAnalyzer()
CriticalCloseable	measureCritical(int path)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CriticalComponentImpl

public CriticalComponentImpl(CriticalAnalyzer analyzer,
                             int numberOfPaths)

Method Detail

getCriticalAnalyzer

public CriticalAnalyzer getCriticalAnalyzer()

Specified by:

getCriticalAnalyzer in interface CriticalComponent

measureCritical

public CriticalCloseable measureCritical(int path)

Specified by:

measureCritical in interface CriticalComponent

checkExpiration

public boolean checkExpiration(long timeout,
                               boolean reset)

Description copied from interface: CriticalComponent

Check if the component is expired at a given timeout.. on any of its paths.

Specified by:

checkExpiration in interface CriticalComponent

Parameters:

timeout - - the timeout to check if the component is expired

reset - - true to reset the component timer if it is expired

Returns:

-1 if it's ok, or the number of the path it failed