public class SerializationGroupMemberContainer<K extends Serializable,V extends Cacheable<K>,G extends Serializable> extends Object implements BackingCacheEntryFactory<K,V,SerializationGroupMember<K,V,G>>, ReplicationPassivationManager<K,SerializationGroupMember<K,V,G>>, BackingCacheEntryStore<K,V,SerializationGroupMember<K,V,G>>
SerializationGroupMembers.| Constructor and Description |
|---|
SerializationGroupMemberContainer(PassivationManager<K,V> passivationManager,
PassivatingBackingCache<G,Cacheable<G>,SerializationGroup<K,V,G>> groupCache,
BackingCacheEntryStoreConfig config) |
| Modifier and Type | Method and Description |
|---|---|
SerializationGroupMember<K,V,G> |
createEntry(V item) |
void |
destroyEntry(SerializationGroupMember<K,V,G> entry) |
SerializationGroupMember<K,V,G> |
get(K key,
boolean lock)
Gets the entry with the given id from the store.
|
BackingCacheEntryStoreConfig |
getConfig() |
org.jboss.marshalling.MarshallingConfiguration |
getMarshallingConfiguration() |
org.jboss.ejb.client.Affinity |
getStrictAffinity()
Returns the strict affinity associated with the entries of this cache
|
StatefulTimeoutInfo |
getTimeout() |
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.
|
Set<K> |
insert(SerializationGroupMember<K,V,G> entry)
Put a new entry into the store.
|
boolean |
isClustered()
Gets whether this store supports clustering functionality.
|
boolean |
isCompatibleWith(GroupCompatibilityChecker other)
Gets whether this object can work compatibly with another in the management of
SerializationGroups. |
boolean |
isCompatibleWith(SerializationGroup<K,V,G> group) |
void |
passivate(SerializationGroupMember<K,V,G> entry)
Remove the entry with the given key from any in-memory store while retaining it in the persistent store.
|
void |
postActivate(SerializationGroupMember<K,V,G> entry)
This method is called after an object has been retrieved deserialized after passivation.
|
void |
postReplicate(SerializationGroupMember<K,V,G> entry)
This method is called after a previously replicated object has been retrieved from a clustered cache.
|
void |
prePassivate(SerializationGroupMember<K,V,G> entry)
This method is called before an object is serialized for passivation.
|
void |
preReplicate(SerializationGroupMember<K,V,G> entry)
This method is called before an object is replicated by a clustered cache.
|
SerializationGroupMember<K,V,G> |
remove(K key)
Remove the object with the given key from the store.
|
void |
setBackingCache(GroupAwareBackingCache<K,V,G,SerializationGroupMember<K,V,G>> delegate) |
void |
setBackingCacheEntryStore(BackingCacheEntryStore<K,V,SerializationGroupMember<K,V,G>> store) |
void |
start()
Perform any initialization work.
|
void |
stop()
Perform any shutdown work.
|
void |
update(SerializationGroupMember<K,V,G> entry,
boolean modified)
Update an already cached item.
|
public SerializationGroupMemberContainer(PassivationManager<K,V> passivationManager, PassivatingBackingCache<G,Cacheable<G>,SerializationGroup<K,V,G>> groupCache, BackingCacheEntryStoreConfig config)
public void setBackingCache(GroupAwareBackingCache<K,V,G,SerializationGroupMember<K,V,G>> delegate)
public void setBackingCacheEntryStore(BackingCacheEntryStore<K,V,SerializationGroupMember<K,V,G>> store)
public org.jboss.ejb.client.Affinity getStrictAffinity()
AffinitySupportgetStrictAffinity in interface AffinitySupport<K extends Serializable>public org.jboss.ejb.client.Affinity getWeakAffinity(K key)
AffinitySupportgetWeakAffinity in interface AffinitySupport<K extends Serializable>public boolean hasAffinity(K key)
AffinitySupporthasAffinity in interface AffinitySupport<K extends Serializable>key - a candidate keypublic org.jboss.marshalling.MarshallingConfiguration getMarshallingConfiguration()
getMarshallingConfiguration in interface PassivationManager<K extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public SerializationGroupMember<K,V,G> createEntry(V item)
createEntry in interface BackingCacheEntryFactory<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public void destroyEntry(SerializationGroupMember<K,V,G> entry)
destroyEntry in interface BackingCacheEntryFactory<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public void postActivate(SerializationGroupMember<K,V,G> entry)
PassivationManagerpostActivate in interface PassivationManager<K extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the objectpublic void prePassivate(SerializationGroupMember<K,V,G> entry)
PassivationManagerprePassivate in interface PassivationManager<K extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the objectpublic void preReplicate(SerializationGroupMember<K,V,G> entry)
ReplicationPassivationManagerpreReplicate in interface ReplicationPassivationManager<K extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the objectpublic void postReplicate(SerializationGroupMember<K,V,G> entry)
ReplicationPassivationManagerpostReplicate in interface ReplicationPassivationManager<K extends Serializable,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the object.public void update(SerializationGroupMember<K,V,G> entry, boolean modified)
BackingCacheEntryStoreupdate in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the entry to updatemodified - was the entry modified since BackingCacheEntryStore.get(java.io.Serializable, boolean) was called?public boolean isClustered()
BackingCacheEntryStoreisClustered in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>true if clustering is supported, false otherwisepublic SerializationGroupMember<K,V,G> get(K key, boolean lock)
BackingCacheEntryStoreget in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>key - id of the entry. Cannot be null.id. May return null.public void passivate(SerializationGroupMember<K,V,G> entry)
BackingCacheEntryStorepassivate in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the entry to passivatepublic Set<K> insert(SerializationGroupMember<K,V,G> entry)
BackingCacheEntryStoreinsert in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>entry - the object to store. Cannot be null.public SerializationGroupMember<K,V,G> remove(K key)
BackingCacheEntryStoreremove in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>key - id of the entry. Cannot be null.keypublic void start()
BackingCacheEntryStorestart in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public void stop()
BackingCacheEntryStorestop in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public BackingCacheEntryStoreConfig getConfig()
getConfig in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public StatefulTimeoutInfo getTimeout()
getTimeout in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>public boolean isCompatibleWith(SerializationGroup<K,V,G> group)
public boolean isCompatibleWith(GroupCompatibilityChecker other)
GroupCompatibilityCheckerSerializationGroups.isCompatibleWith in interface GroupCompatibilityCheckerother - the other checker. May be null.true if this object is compatible with other, false otherwiseCopyright © 2013 JBoss, a division of Red Hat, Inc.. All Rights Reserved.