Package de.hybris.platform.tx

Class InvalidationSet

java.lang.Object

de.hybris.platform.tx.InvalidationSet

Direct Known Subclasses:

Transaction.TxInvalidationSet

@NotThreadSafe
public class InvalidationSet
extends Object

Collects delayed invalidations and records simulated / derived invalidations too.

This class is intended to be used inside a running transaction and therefore should be used by one thread only!

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	InvalidationSet.Invalidation	Invalidation object representation.
static class	InvalidationSet.InvalidationManagerProcessor	Invalidation processor based on InvalidationManager.
static interface	InvalidationSet.InvalidationProcessor	Interface for performing actual invalidation during executeDelayedInvalidationsGlobally(), executeDelayedInvalidationsLocally() or executeDelayedRollbackInvalidationsLocally().

Field Summary

Fields

Modifier and Type	Field	Description
static InvalidationSet	EMPTY_SET	Empty immutable invalidation set.

Constructor Summary

Constructors

Constructor	Description
InvalidationSet()
InvalidationSet(InvalidationSet.InvalidationProcessor processor)

Method Summary

Modifier and Type	Method	Description
InvalidationSet.Invalidation	addInvalidation(Object[] key, int invalidationTopicDepth, int invalidationType)	Registers a invalidation without dry-running it.
static InvalidationSet.Invalidation	createInvalidation(Object[] key, int invalidationTopicDepth, int invalidationType)	Allows to create a standalone InvalidationSet.Invalidation instance.
InvalidationSet.Invalidation	delayInvalidation(Object[] key, int invalidationTopicDepth, int invalidationType)	Registers a new invalidation and dry-runs it using existing topics and listeners in order to record derived invalidations too.
InvalidationSet.Invalidation	delayRollbackInvalidation(Object[] key, int invalidationTopicDepth, int invalidationType)	Registers a invalidation for rollback.
void	executeDelayedInvalidationsGlobally()	Executes all recorded InvalidationSet.Invalidation objects that have been registered via delayRollbackInvalidation(Object[], int, int).
void	executeDelayedInvalidationsLocally()	Executes all recorded InvalidationSet.Invalidation objects that have been registered via delayInvalidation(Object[], int, int).
void	executeDelayedRollbackInvalidationsLocally()	Executes all recorded InvalidationSet.Invalidation objects that have been registered via delayRollbackInvalidation(Object[], int, int).
protected InvalidationTarget	getRealInvalidationTarget()
static void	invalidateGlobally(InvalidationSet.Invalidation invalidation)
static void	invalidateGlobally(Collection<InvalidationSet.Invalidation> invalidations)
static void	invalidateLocally(Collection<InvalidationSet.Invalidation> invalidations)
boolean	isEmpty()	Tells whether this container has recorded any derived invalidation.
boolean	isInvalidated(Object[] key)	Checks whether a specific key can be considered to be invalidated according to all recorded derived invalidations.
protected void	singleKeyHasBeenInvalidated(Object[] key)

Methods inherited from class java.lang.Object

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

Field Details

EMPTY_SET

public static InvalidationSet EMPTY_SET

Empty immutable invalidation set. Will throw UnsupportedOperationException when calling any update method.

Constructor Details

InvalidationSet

public InvalidationSet()

InvalidationSet

public InvalidationSet(InvalidationSet.InvalidationProcessor processor)

Method Details

createInvalidation

public static InvalidationSet.Invalidation createInvalidation(Object[] key,
 int invalidationTopicDepth,
 int invalidationType)

Allows to create a standalone InvalidationSet.Invalidation instance. Use it to execute local or global invalidations via invalidateGlobally(Collection) or invalidateLocally(Collection).

invalidateGlobally

public static void invalidateGlobally(InvalidationSet.Invalidation invalidation)

invalidateGlobally

public static void invalidateGlobally(Collection<InvalidationSet.Invalidation> invalidations)

invalidateLocally

public static void invalidateLocally(Collection<InvalidationSet.Invalidation> invalidations)

executeDelayedInvalidationsGlobally

public void executeDelayedInvalidationsGlobally()

Executes all recorded InvalidationSet.Invalidation objects that have been registered via delayRollbackInvalidation(Object[], int, int).

These will become effective globally which means that cache invalidation packets will be set to other cluster nodes as well!

getRealInvalidationTarget

protected InvalidationTarget getRealInvalidationTarget()

executeDelayedInvalidationsLocally

public void executeDelayedInvalidationsLocally()

Executes all recorded InvalidationSet.Invalidation objects that have been registered via delayInvalidation(Object[], int, int).

They will become effective only locally which means that no cache invalidation packets will be set to other cluster nodes!

executeDelayedRollbackInvalidationsLocally

public void executeDelayedRollbackInvalidationsLocally()

Executes all recorded InvalidationSet.Invalidation objects that have been registered via delayRollbackInvalidation(Object[], int, int).

They will become effective only locally which means that no cache invalidation packets will be set to other cluster nodes!

delayInvalidation

public InvalidationSet.Invalidation delayInvalidation(Object[] key,
 int invalidationTopicDepth,
 int invalidationType)

Registers a new invalidation and dry-runs it using existing topics and listeners in order to record derived invalidations too. As a result isInvalidated(Object[]) will respect not just this invalidation but also all derived ones.

It does not invalidate the real cache here!

addInvalidation

public InvalidationSet.Invalidation addInvalidation(Object[] key,
 int invalidationTopicDepth,
 int invalidationType)

Registers a invalidation without dry-running it. Therefore derived invalidations will not be recorded thus this has no effect on isInvalidated(Object[])!

delayRollbackInvalidation

public InvalidationSet.Invalidation delayRollbackInvalidation(Object[] key,
 int invalidationTopicDepth,
 int invalidationType)

Registers a invalidation for rollback. It will not be dry-run, which means that derived invalidations will not be recorded so this has no effect on isInvalidated(Object[])!

singleKeyHasBeenInvalidated

protected void singleKeyHasBeenInvalidated(Object[] key)

isEmpty

public boolean isEmpty()

Tells whether this container has recorded any derived invalidation.

isInvalidated

public boolean isInvalidated(Object[] key)

Checks whether a specific key can be considered to be invalidated according to all recorded derived invalidations.