|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.mx.util.JBossNotificationBroadcasterSupport
org.jboss.system.ServiceMBeanSupport
org.jboss.cache.invalidation.bridges.JGCacheInvalidationBridge
public class JGCacheInvalidationBridge
JGroups implementation of a cache invalidation bridge
Revisions:
24 septembre 2002 Sacha Labourey:
JGCacheInvalidationBridgeMBean
Field Summary | |
---|---|
protected Vector |
bridgedGroups
|
protected String |
bridgeName
|
protected BridgeInvalidationSubscription |
invalidationSubscription
|
protected InvalidationManagerMBean |
invalMgr
|
protected Collection |
localGroups
|
protected org.jboss.ha.framework.interfaces.HAPartition |
partition
The ClusterPartition with which we are associated. |
protected static Class[] |
rpc_batch_invalidate_types
|
protected String |
RPC_HANDLER_NAME
|
protected static Class[] |
rpc_invalidate_all_types
|
protected static Class[] |
rpc_invalidate_types
|
protected static Class[] |
rpc_invalidates_types
|
Fields inherited from class org.jboss.system.ServiceMBeanSupport |
---|
log, server, SERVICE_CONTROLLER_SIG, serviceName |
Fields inherited from interface org.jboss.system.ServiceMBean |
---|
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED |
Constructor Summary | |
---|---|
JGCacheInvalidationBridge()
|
Method Summary | |
---|---|
protected void |
_do_rpc_batchInvalidate(BatchInvalidation[] invalidations,
boolean asynch)
|
protected void |
_do_rpc_invalidate_all(String invalidationGroupName,
boolean asynch)
|
protected void |
_do_rpc_invalidate(String invalidationGroupName,
Serializable key,
boolean asynch)
|
protected void |
_do_rpc_invalidates(String invalidationGroupName,
Serializable[] keys,
boolean asynch)
|
void |
_rpc_batchInvalidate(BatchInvalidation[] invalidations)
|
void |
_rpc_invalidate_all(String invalidationGroupName)
|
void |
_rpc_invalidate(String invalidationGroupName,
Serializable key)
|
void |
_rpc_invalidates(String invalidationGroupName,
Serializable[] keys)
|
void |
batchInvalidate(BatchInvalidation[] invalidations,
boolean asynchronous)
|
String |
getBridgeName()
Get the invalidation bridge name. |
org.jboss.ha.framework.interfaces.HAPartition |
getHAPartition()
Get the underlying partition used by this service to exchange invalidation messages and discover which caches (i.e., InvalidationGroup) are available. |
InvalidationManagerMBean |
getInvalidationManager()
Get the InvalidationManager |
String |
getPartitionName()
Gets the name of the partition to be used to exchange invalidation messages and discover which caches (i.e., InvalidationGroup)are available. |
protected boolean |
groupExistsRemotely(String groupName)
|
void |
groupIsDropped(String groupInvalidationName)
|
void |
invalidate(String invalidationGroupName,
Serializable[] keys,
boolean asynchronous)
|
void |
invalidate(String invalidationGroupName,
Serializable key,
boolean asynchronous)
|
void |
invalidateAll(String groupName,
boolean async)
|
void |
keyHasBeenRemoved(String category,
Serializable key,
Serializable previousContent,
boolean locallyModified)
|
void |
newGroupCreated(String groupInvalidationName)
|
protected void |
publishLocalInvalidationGroups()
|
void |
replicantsChanged(String key,
List newReplicants,
int newReplicantsViewId,
boolean merge)
|
void |
setBridgeName(String name)
Set the invalidation bridge name |
void |
setHAPartition(org.jboss.ha.framework.interfaces.HAPartition clusterPartition)
Sets the underlying partition used by this service to exchange invalidation messages and discover which caches (i.e., InvalidationGroup) are available |
void |
setInvalidationManager(InvalidationManagerMBean manager)
Set the InvalidationManager |
void |
startService()
|
void |
stopService()
|
protected void |
updatedBridgedInvalidationGroupsInfo()
|
void |
valueHasChanged(String category,
Serializable key,
Serializable value,
boolean locallyModified)
|
Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport |
---|
addNotificationListener, getNotificationInfo, handleNotification, nextNotificationSequenceNumber, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.jboss.system.ServiceMBean |
---|
getName, getState, getStateString, jbossInternalLifecycle |
Methods inherited from interface org.jboss.system.Service |
---|
create, destroy, start, stop |
Field Detail |
---|
protected static final Class[] rpc_invalidate_types
protected static final Class[] rpc_invalidates_types
protected static final Class[] rpc_invalidate_all_types
protected static final Class[] rpc_batch_invalidate_types
protected volatile org.jboss.ha.framework.interfaces.HAPartition partition
protected volatile String bridgeName
protected volatile InvalidationManagerMBean invalMgr
protected String RPC_HANDLER_NAME
protected BridgeInvalidationSubscription invalidationSubscription
protected Collection localGroups
protected Vector bridgedGroups
Constructor Detail |
---|
public JGCacheInvalidationBridge()
Method Detail |
---|
public org.jboss.ha.framework.interfaces.HAPartition getHAPartition()
JGCacheInvalidationBridgeMBean
getHAPartition
in interface JGCacheInvalidationBridgeMBean
public void setHAPartition(org.jboss.ha.framework.interfaces.HAPartition clusterPartition)
JGCacheInvalidationBridgeMBean
setHAPartition
in interface JGCacheInvalidationBridgeMBean
clusterPartition
- the partitionpublic String getPartitionName()
JGCacheInvalidationBridgeMBean
getPartitionName
in interface JGCacheInvalidationBridgeMBean
public String getBridgeName()
JGCacheInvalidationBridgeMBean
getBridgeName
in interface JGCacheInvalidationBridgeMBean
public void setBridgeName(String name)
JGCacheInvalidationBridgeMBean
setBridgeName
in interface JGCacheInvalidationBridgeMBean
name
- of the bridgepublic void replicantsChanged(String key, List newReplicants, int newReplicantsViewId, boolean merge)
replicantsChanged
in interface org.jboss.ha.framework.interfaces.DistributedReplicantManager.ReplicantListener
public void valueHasChanged(String category, Serializable key, Serializable value, boolean locallyModified)
valueHasChanged
in interface org.jboss.ha.framework.interfaces.DistributedState.DSListenerEx
public void keyHasBeenRemoved(String category, Serializable key, Serializable previousContent, boolean locallyModified)
keyHasBeenRemoved
in interface org.jboss.ha.framework.interfaces.DistributedState.DSListenerEx
public void batchInvalidate(BatchInvalidation[] invalidations, boolean asynchronous)
batchInvalidate
in interface InvalidationBridgeListener
public void invalidate(String invalidationGroupName, Serializable[] keys, boolean asynchronous)
invalidate
in interface InvalidationBridgeListener
public void invalidate(String invalidationGroupName, Serializable key, boolean asynchronous)
invalidate
in interface InvalidationBridgeListener
public void invalidateAll(String groupName, boolean async)
invalidateAll
in interface InvalidationBridgeListener
public void newGroupCreated(String groupInvalidationName)
newGroupCreated
in interface InvalidationBridgeListener
public void groupIsDropped(String groupInvalidationName)
groupIsDropped
in interface InvalidationBridgeListener
public InvalidationManagerMBean getInvalidationManager()
JGCacheInvalidationBridgeMBean
getInvalidationManager
in interface JGCacheInvalidationBridgeMBean
public void setInvalidationManager(InvalidationManagerMBean manager)
JGCacheInvalidationBridgeMBean
setInvalidationManager
in interface JGCacheInvalidationBridgeMBean
public void startService() throws Exception
startService
in class ServiceMBeanSupport
Exception
public void stopService()
stopService
in class ServiceMBeanSupport
public void _rpc_invalidate(String invalidationGroupName, Serializable key)
public void _rpc_invalidates(String invalidationGroupName, Serializable[] keys)
public void _rpc_invalidate_all(String invalidationGroupName)
public void _rpc_batchInvalidate(BatchInvalidation[] invalidations)
protected void _do_rpc_invalidate(String invalidationGroupName, Serializable key, boolean asynch)
protected void _do_rpc_invalidates(String invalidationGroupName, Serializable[] keys, boolean asynch)
protected void _do_rpc_invalidate_all(String invalidationGroupName, boolean asynch)
protected void _do_rpc_batchInvalidate(BatchInvalidation[] invalidations, boolean asynch)
protected void publishLocalInvalidationGroups() throws Exception
Exception
protected void updatedBridgedInvalidationGroupsInfo()
protected boolean groupExistsRemotely(String groupName)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |