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>>
SerializationGroupMember
s.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
SerializationGroup s. |
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()
AffinitySupport
getStrictAffinity
in interface AffinitySupport<K extends Serializable>
public org.jboss.ejb.client.Affinity getWeakAffinity(K key)
AffinitySupport
getWeakAffinity
in interface AffinitySupport<K extends Serializable>
public boolean hasAffinity(K key)
AffinitySupport
hasAffinity
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)
PassivationManager
postActivate
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)
PassivationManager
prePassivate
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)
ReplicationPassivationManager
preReplicate
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)
ReplicationPassivationManager
postReplicate
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)
BackingCacheEntryStore
update
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()
BackingCacheEntryStore
isClustered
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)
BackingCacheEntryStore
get
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)
BackingCacheEntryStore
passivate
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)
BackingCacheEntryStore
insert
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)
BackingCacheEntryStore
remove
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
.key
public void start()
BackingCacheEntryStore
start
in interface BackingCacheEntryStore<K extends Serializable,V extends Cacheable<K>,SerializationGroupMember<K extends Serializable,V extends Cacheable<K>,G extends Serializable>>
public void stop()
BackingCacheEntryStore
stop
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)
GroupCompatibilityChecker
SerializationGroup
s.isCompatibleWith
in interface GroupCompatibilityChecker
other
- 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.