org.infinispan.xsite

Class BackupReceiverRepositoryImpl

java.lang.Object

org.infinispan.xsite.BackupReceiverRepositoryImpl

All Implemented Interfaces:

BackupReceiverRepository

public class BackupReceiverRepositoryImpl
extends Object
implements BackupReceiverRepository

Since:

5.2

Author:

Mircea Markus

Field Summary

Fields

Modifier and Type	Field and Description
EmbeddedCacheManager	cacheManager

Constructor Summary

Constructors

Constructor and Description
BackupReceiverRepositoryImpl()

Method Summary

Methods

Modifier and Type	Method and Description
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)