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 String
void
deferredDebug
(String message) Deferred debug, that will be used in case certain conditions apply to the RefCountMessagestatic void
deferredDebug
(Message message, String debugMessage, Object... args) static void
deferredDebug
(RefCountMessage message, String debugMessage, Object... args) void
int
int
int
int
int
getUsage()
getUserContext
(Object key) static boolean
static boolean
boolean
has the refCount fired the action already?protected void
onDown()
protected void
onUp()
int
refDown()
int
refUp()
protected void
Sub classes constructors willing to debug reference counts, can register the objectCleaner through this method.protected void
protected void
released()
void
setParentRef
(RefCountMessage origin) void
setUserContext
(Object key, Object value) int
int
usageUp()
-
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
-