com.arjuna.webservices.base.processors

Class ReactivatedObjectProcessor

java.lang.Object

com.arjuna.webservices.base.processors.ActivatedObjectProcessor

com.arjuna.webservices.base.processors.ReactivatedObjectProcessor

public class ReactivatedObjectProcessor
extends ActivatedObjectProcessor

A specialization of ActivatedObjectProcessor which allows for ghost entries to be left in the table after deletion. A ghost entry cannot be retrieved by a normal getObject(id) which will return null, indicating that no object with the supplied id exists. However, the ghost's presence can be detected using getGhost(id).

Ghost entries are used to identify objects which have failed to be terminated due to an unavailable participant or coordinator and so are still present in an unprocessed log record. When recovery processing recreates a participant the recovered instance replaces the ghost entry, ensuring that sbsequent messages update the participant whose recovery is being driven by the coordinator.

Field Summary

Fields inherited from class com.arjuna.webservices.base.processors.ActivatedObjectProcessor

identifierMap, objectMap

Constructor Summary

Constructors

Constructor and Description
ReactivatedObjectProcessor()

Method Summary

Modifier and Type	Method and Description
void	activateObject(Object object, String identifier) Activate the object.
void	deactivateObject(Object object) Deactivate the object.
void	deactivateObject(Object object, boolean leaveGhost) Deactivate the object.
boolean	getGhost(String identifier) check if there is a ghost entry for this object
Object	getObject(String identifier) Get the object with the specified identifier.
static void	setReactivationProcessingStarted() notify completion of a recovery log scan for XTS data

Methods inherited from class com.arjuna.webservices.base.processors.ActivatedObjectProcessor

count

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactivatedObjectProcessor

public ReactivatedObjectProcessor()

Method Detail

activateObject

public void activateObject(Object object,
                           String identifier)

Activate the object.

Overrides:

activateObject in class ActivatedObjectProcessor

Parameters:

object - The object.

identifier - The identifier.

deactivateObject

public void deactivateObject(Object object)

Deactivate the object.

Overrides:

deactivateObject in class ActivatedObjectProcessor

Parameters:

object - The object.

deactivateObject

public void deactivateObject(Object object,
                             boolean leaveGhost)

Deactivate the object.

Parameters:

object - The object.

getObject

public Object getObject(String identifier)

Get the object with the specified identifier.

Overrides:

getObject in class ActivatedObjectProcessor

Parameters:

identifier - The identifier.

Returns:

The participant or null if not known.

getGhost

public boolean getGhost(String identifier)

check if there is a ghost entry for this object

Parameters:

identifier -

Returns:

true iff there is a ghost entry for this object

setReactivationProcessingStarted

public static void setReactivationProcessingStarted()

notify completion of a recovery log scan for XTS data