org.jboss.as.ejb3.cache.impl.backing

Class GroupAwareBackingCacheImpl<K extends Serializable,V extends Cacheable<K>,G extends Serializable>

java.lang.Object

org.jboss.as.ejb3.cache.spi.impl.AbstractBackingCache<K,V,E>

org.jboss.as.ejb3.cache.impl.backing.PassivatingBackingCacheImpl<K,V,SerializationGroupMember<K,V,G>>

org.jboss.as.ejb3.cache.impl.backing.GroupAwareBackingCacheImpl<K,V,G>

All Implemented Interfaces:

AffinitySupport<K>, Removable<K>, BackingCache<K,V,SerializationGroupMember<K,V,G>>, GroupAwareBackingCache<K,V,G,SerializationGroupMember<K,V,G>>, Passivatable<K>, PassivatingBackingCache<K,V,SerializationGroupMember<K,V,G>>

public class GroupAwareBackingCacheImpl<K extends Serializable,V extends Cacheable<K>,G extends Serializable>
extends PassivatingBackingCacheImpl<K,V,SerializationGroupMember<K,V,G>>
implements GroupAwareBackingCache<K,V,G,SerializationGroupMember<K,V,G>>

Group-aware version of PassivatingBackingCacheImpl.

Author:

Brian Stansberry, Paul Ferraro

Field Summary

Fields inherited from class org.jboss.as.ejb3.cache.impl.backing.PassivatingBackingCacheImpl

log

Constructor Summary

Constructors

Constructor and Description
GroupAwareBackingCacheImpl(StatefulObjectFactory<V> factory, SerializationGroupMemberContainer<K,V,G> memberContainer, PassivatingBackingCache<G,Cacheable<G>,SerializationGroup<K,V,G>> groupCache, ScheduledExecutorService executor)
GroupAwareBackingCacheImpl(StatefulObjectFactory<V> factory, SerializationGroupMemberContainer<K,V,G> memberContainer, PassivatingBackingCache<G,Cacheable<G>,SerializationGroup<K,V,G>> groupCache, ThreadFactory threadFactory) Creates a new GroupAwareCacheImpl.

Method Summary

Methods

Modifier and Type	Method and Description
SerializationGroup<K,V,G>	createGroup() Create a SerializationGroup to contain objects cached by this object.
org.jboss.ejb.client.Affinity	getWeakAffinity(K key) Returns the weak affinity associated with the specified entry of this cache
boolean	hasAffinity(K key) Indicates whether the cache has an affinity for the specified key.
void	notifyPreReplicate(SerializationGroupMember<K,V,G> entry) Callback from the group informing the cache it needs to invoke pre-replication callbacks on the member.
void	setGroup(V object, SerializationGroup<K,V,G> group) Assign the given object to the given group.

Methods inherited from class org.jboss.as.ejb3.cache.impl.backing.PassivatingBackingCacheImpl

create, discard, get, getCompatibilityChecker, getStrictAffinity, isClustered, passivate, peek, release, remove, start, stop

Methods inherited from class org.jboss.as.ejb3.cache.spi.impl.AbstractBackingCache

addLifecycleListener, notifyLifecycleListeners, removeLifecycleListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.as.ejb3.cache.spi.PassivatingBackingCache

getCompatibilityChecker

Methods inherited from interface org.jboss.as.ejb3.cache.spi.BackingCache

addLifecycleListener, create, discard, get, isClustered, peek, release, removeLifecycleListener, start, stop

Methods inherited from interface org.jboss.as.ejb3.cache.Removable

remove

Methods inherited from interface org.jboss.as.ejb3.cache.AffinitySupport

getStrictAffinity

Methods inherited from interface org.jboss.as.ejb3.cache.spi.Passivatable

passivate

Constructor Detail

GroupAwareBackingCacheImpl

public GroupAwareBackingCacheImpl(StatefulObjectFactory<V> factory,
                          SerializationGroupMemberContainer<K,V,G> memberContainer,
                          PassivatingBackingCache<G,Cacheable<G>,SerializationGroup<K,V,G>> groupCache,
                          ThreadFactory threadFactory)

Creates a new GroupAwareCacheImpl.

Parameters:

memberContainer - the factory for the underlying Cacheables

groupCache - cache for the group

GroupAwareBackingCacheImpl

public GroupAwareBackingCacheImpl(StatefulObjectFactory<V> factory,
                          SerializationGroupMemberContainer<K,V,G> memberContainer,
                          PassivatingBackingCache<G,Cacheable<G>,SerializationGroup<K,V,G>> groupCache,
                          ScheduledExecutorService executor)

Method Detail

hasAffinity

public boolean hasAffinity(K key)

Description copied from interface: AffinitySupport

Indicates whether the cache has an affinity for the specified key.

Specified by:

hasAffinity in interface AffinitySupport<K extends Serializable>

Overrides:

hasAffinity in class PassivatingBackingCacheImpl<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>

Parameters:

key - a candidate key

Returns:

true if this cache likes this key, false otherwise

getWeakAffinity

public org.jboss.ejb.client.Affinity getWeakAffinity(K key)

Description copied from interface: AffinitySupport

Returns the weak affinity associated with the specified entry of this cache

Specified by:

getWeakAffinity in interface AffinitySupport<K extends Serializable>

Overrides:

getWeakAffinity in class PassivatingBackingCacheImpl<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>

createGroup

public SerializationGroup<K,V,G> createGroup()

Description copied from interface: GroupAwareBackingCache

Create a SerializationGroup to contain objects cached by this object.

Specified by:

createGroup in interface GroupAwareBackingCache<K extends Serializable,V extends Cacheable<K>,G extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>

Returns:

a SerializationGroup

setGroup

public void setGroup(V object,
            SerializationGroup<K,V,G> group)

Description copied from interface: GroupAwareBackingCache

Assign the given object to the given group. The group will be of the SerializationGroup implementation type returned by GroupAwareBackingCache.createGroup().

Specified by:

setGroup in interface GroupAwareBackingCache<K extends Serializable,V extends Cacheable<K>,G extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>

notifyPreReplicate

public void notifyPreReplicate(SerializationGroupMember<K,V,G> entry)

Description copied from interface: GroupAwareBackingCache

Callback from the group informing the cache it needs to invoke pre-replication callbacks on the member.

Specified by:

notifyPreReplicate in interface GroupAwareBackingCache<K extends Serializable,V extends Cacheable<K>,G extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>

Parameters:

entry - the group member