Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.xsite
Class BackupReceiverRepositoryImpl

java.lang.Object
  extended by org.infinispan.xsite.BackupReceiverRepositoryImpl
All Implemented Interfaces:
BackupReceiverRepository

public class BackupReceiverRepositoryImpl
extends Object
implements BackupReceiverRepository

Since:
5.2
Author:
Mircea Markus

Field Summary
 EmbeddedCacheManager cacheManager
           
 
Constructor Summary
BackupReceiverRepositoryImpl()
           
 
Method Summary
 void cacheStopped(CacheStoppedEvent cse)
           
 BackupReceiver getBackupCacheManager(String remoteSite, String remoteCache)
          Returns the local cache associated defined as backup for the provided remote (site, cache) combo, or throws an exception of no such site is defined.
 BackupReceiver getBackupReceiver(String site, String cache)
           
 Object handleRemoteCommand(SingleRpcCommand cmd, org.jgroups.protocols.relay.SiteAddress src)
          Process an CacheRpcCommand received from a remote site.
 void replace(String site, String cache, BackupReceiver bcr)
           
 void setup(EmbeddedCacheManager cacheManager)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

cacheManager

public EmbeddedCacheManager cacheManager
Constructor Detail

BackupReceiverRepositoryImpl

public BackupReceiverRepositoryImpl()
Method Detail

setup

public void setup(EmbeddedCacheManager cacheManager)

start

public void start()

stop

public void stop()

cacheStopped

public void cacheStopped(CacheStoppedEvent cse)

handleRemoteCommand

public Object handleRemoteCommand(SingleRpcCommand cmd,
                                  org.jgroups.protocols.relay.SiteAddress src)
                           throws Throwable
Description copied from interface: BackupReceiverRepository
Process an CacheRpcCommand received from a remote site.

Specified by:
handleRemoteCommand in interface BackupReceiverRepository
Throws:
Throwable

getBackupCacheManager

public BackupReceiver getBackupCacheManager(String remoteSite,
                                            String remoteCache)
Returns the local cache associated defined as backup for the provided remote (site, cache) combo, or throws an exception of no such site is defined.

Also starts the cache if not already stated; that is because the cache is needed for update after when this method is invoked.


replace

public void replace(String site,
                    String cache,
                    BackupReceiver bcr)

getBackupReceiver

public BackupReceiver getBackupReceiver(String site,
                                        String cache)

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.