Class RefCountMessage
java.lang.Object
org.apache.activemq.artemis.api.core.RefCountMessage
RefCountMessage is a base-class for any message intending to do reference counting. Currently it is used for large
message removal.
Additional validation on reference counting will be done If you set a system property named "ARTEMIS_REF_DEBUG" and enable logging on this class. Additional logging output will be written when reference counting is broken and these debug options are applied.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected StringvoiddeferredDebug(String message) Deferred debug, that will be used in case certain conditions apply to the RefCountMessagestatic voiddeferredDebug(Message message, String debugMessage, Object... args) static voiddeferredDebug(RefCountMessage message, String debugMessage, Object... args) voidintintintintintgetUsage()getUserContext(Object key) static booleanstatic booleanbooleanhas the refCount fired the action already?protected voidonDown()protected voidonUp()intrefDown()intrefUp()protected voidSub classes constructors willing to debug reference counts, can register the objectCleaner through this method.protected voidprotected voidreleased()voidsetParentRef(RefCountMessage origin) voidsetUserContext(Object key, Object value) intintusageUp()
-
Constructor Details
-
RefCountMessage
public RefCountMessage()
-
-
Method Details
-
isRefDebugEnabled
public static boolean isRefDebugEnabled() -
isRefTraceEnabled
public static boolean isRefTraceEnabled() -
registerDebug
protected void registerDebug()Sub classes constructors willing to debug reference counts, can register the objectCleaner through this method. -
isReleased
public boolean isReleased()has the refCount fired the action already? -
debugLocations
-
deferredDebug
-
deferredDebug
-
deferredDebug
Deferred debug, that will be used in case certain conditions apply to the RefCountMessage -
getRefCount
public int getRefCount() -
getUsage
public int getUsage() -
getDurableCount
public int getDurableCount() -
getParentRef
-
onUp
protected void onUp() -
released
protected void released() -
disableErrorCheck
public void disableErrorCheck() -
onDown
protected void onDown() -
counterString
-
setParentRef
-
releaseComplete
protected void releaseComplete() -
usageUp
public int usageUp() -
usageDown
public int usageDown() -
durableUp
public int durableUp() -
durableDown
public int durableDown() -
refDown
public int refDown() -
refUp
public int refUp() -
getUserContext
-
setUserContext
-