com.atlassian.confluence.impl.index

Class DefaultIndexRecoveryService

java.lang.Object

com.atlassian.confluence.impl.index.DefaultIndexRecoveryService

All Implemented Interfaces:

IndexRecoveryService, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class DefaultIndexRecoveryService
extends Object
implements IndexRecoveryService, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

This is the default implementation of IndexRecoveryService.

Since:

5.8

Constructor Summary

Constructors

Constructor and Description
DefaultIndexRecoveryService(JournalStateStore journalStateStore, JournalDao journalDao, ClusterManager clusterManager, com.atlassian.event.api.EventPublisher eventPublisher, ClusterEventWrapperService clusterEventWrapperService, com.atlassian.plugin.PluginAccessor pluginAccessor)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
void	handleEvent(ClusterEventWrapper eventWrapper)
boolean	isIndexRecoveryRequired(JournalIdentifier journalId, String indexDirName) Checks to see whether the index needs to be recovered.
boolean	recoverIndex(JournalIdentifier journalId, String indexDirName) Recovers the index required by asking other nodes in the cluster for a snapshot of their index and copying it to its local home directory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultIndexRecoveryService

public DefaultIndexRecoveryService(JournalStateStore journalStateStore,
                                   JournalDao journalDao,
                                   ClusterManager clusterManager,
                                   com.atlassian.event.api.EventPublisher eventPublisher,
                                   ClusterEventWrapperService clusterEventWrapperService,
                                   com.atlassian.plugin.PluginAccessor pluginAccessor)

Method Detail

isIndexRecoveryRequired

public boolean isIndexRecoveryRequired(JournalIdentifier journalId,
                                       String indexDirName)

Description copied from interface: IndexRecoveryService

Checks to see whether the index needs to be recovered. This will be true if the index folder does not exist, or, if the index is copied over from a live system and is invalid, or, if the journal has been purged past where the node is currently processing, Note, this will always return false if the instance is not clustered.

Specified by:

isIndexRecoveryRequired in interface IndexRecoveryService

Parameters:

journalId - the index to check whether it needs to be recovered

indexDirName - the name of the subdirectory containing the Lucene index

recoverIndex

public boolean recoverIndex(JournalIdentifier journalId,
                            String indexDirName)

Description copied from interface: IndexRecoveryService

Recovers the index required by asking other nodes in the cluster for a snapshot of their index and copying it to its local home directory. This will overwrite the local index files if it already exists.

Specified by:

recoverIndex in interface IndexRecoveryService

Parameters:

journalId - the index to recover

indexDirName - the name of the subdirectory containing the Lucene index

Returns:

true if index recovery has been requested, false otherwise.

handleEvent

@EventListener
public void handleEvent(ClusterEventWrapper eventWrapper)
                                throws Exception

Throws:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception