org.codehaus.wadi.replication.manager.basic
Class LoggingReplicationManager

java.lang.Object
  extended by org.codehaus.wadi.replication.manager.basic.LoggingReplicationManager
All Implemented Interfaces:
Lifecycle, ReplicationManager

public class LoggingReplicationManager
extends java.lang.Object
implements ReplicationManager

Version:
$Rev:$ $Date:$

Field Summary
 
Fields inherited from interface org.codehaus.wadi.replication.manager.ReplicationManager
NAME
 
Constructor Summary
LoggingReplicationManager(ReplicationManager delegate)
           
 
Method Summary
 void create(java.lang.Object key, Motable tmp)
           
 void destroy(java.lang.Object key)
           
 java.util.Set<java.lang.Object> getManagedReplicaInfoKeys()
           
 void insertReplicaInfo(java.lang.Object key, ReplicaInfo replicaInfo)
           
 void promoteToMaster(java.lang.Object key, ReplicaInfo replicaInfo, Motable motable, Peer blackListedSecondary)
           
 ReplicaInfo releaseReplicaInfo(java.lang.Object key, Peer newPrimary)
           
 Motable retrieveReplica(java.lang.Object key)
           
 void start()
           
 void stop()
           
 void update(java.lang.Object key, Motable tmp)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LoggingReplicationManager

public LoggingReplicationManager(ReplicationManager delegate)
Method Detail

create

public void create(java.lang.Object key,
                   Motable tmp)
            throws ReplicationKeyAlreadyExistsException,
                   InternalReplicationManagerException
Specified by:
create in interface ReplicationManager
Throws:
ReplicationKeyAlreadyExistsException
InternalReplicationManagerException

destroy

public void destroy(java.lang.Object key)
Specified by:
destroy in interface ReplicationManager

getManagedReplicaInfoKeys

public java.util.Set<java.lang.Object> getManagedReplicaInfoKeys()
Specified by:
getManagedReplicaInfoKeys in interface ReplicationManager

insertReplicaInfo

public void insertReplicaInfo(java.lang.Object key,
                              ReplicaInfo replicaInfo)
                       throws ReplicationKeyAlreadyExistsException
Specified by:
insertReplicaInfo in interface ReplicationManager
Throws:
ReplicationKeyAlreadyExistsException

releaseReplicaInfo

public ReplicaInfo releaseReplicaInfo(java.lang.Object key,
                                      Peer newPrimary)
Specified by:
releaseReplicaInfo in interface ReplicationManager

retrieveReplica

public Motable retrieveReplica(java.lang.Object key)
                        throws InternalReplicationManagerException
Specified by:
retrieveReplica in interface ReplicationManager
Throws:
InternalReplicationManagerException

promoteToMaster

public void promoteToMaster(java.lang.Object key,
                            ReplicaInfo replicaInfo,
                            Motable motable,
                            Peer blackListedSecondary)
                     throws InternalReplicationManagerException
Specified by:
promoteToMaster in interface ReplicationManager
Throws:
InternalReplicationManagerException

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Lifecycle
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Lifecycle
Throws:
java.lang.Exception

update

public void update(java.lang.Object key,
                   Motable tmp)
            throws ReplicationKeyNotFoundException,
                   InternalReplicationManagerException
Specified by:
update in interface ReplicationManager
Throws:
ReplicationKeyNotFoundException
InternalReplicationManagerException


Copyright © 2011. All Rights Reserved.