inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-24 17:32:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Context to disable avm indexing

Browse Source 
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@5716 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Andrew Hind
2007-05-18 08:22:03 +00:00
parent 19ce257baa
commit 5a8f9282b6
3 changed files with 104 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
config/alfresco/extension/disabled-avm-indexing-context.xml.sample Normal file
View File

@@ -0,0 +1,19 @@
<?xml version='1.0' encoding='UTF-8'?>
<!DOCTYPE beans PUBLIC '-//SPRING//DTD BEAN//EN' 'http://www.springframework.org/dtd/spring-beans.dtd'>
<beans>
<!-- disable avm indexing -->
<bean id="avmSnapShotTriggeredIndexingMethodInterceptor" class="org.alfresco.repo.search.AVMSnapShotTriggeredIndexingMethodInterceptor">
<property name="avmService">
<ref bean="avmService" />
</property>
<property name="indexerAndSearcher">
<ref bean="avmLuceneIndexerAndSearcherFactory" />
</property>
<property name="enableIndexing">
<value>false</value>
</property>
</bean>
</beans>

3
config/alfresco/public-services-context.xml
View File

@@ -862,6 +862,9 @@
<property name="indexerAndSearcher">
<ref bean="avmLuceneIndexerAndSearcherFactory" />
</property>
<property name="enableIndexing">
<value>true</value>
</property>
</bean>
<!-- The AVMSyncService -->

143
source/java/org/alfresco/repo/search/AVMSnapShotTriggeredIndexingMethodInterceptor.java
View File

@@ -35,94 +35,102 @@ import org.aopalliance.intercept.MethodInvocation;
* Method interceptor for atomic indexing of AVM entries
*
* @author andyh
*
*/
public class AVMSnapShotTriggeredIndexingMethodInterceptor implements MethodInterceptor
{
private AVMService avmService;
private IndexerAndSearcher indexerAndSearcher;
private boolean enableIndexing = true;
public Object invoke(MethodInvocation mi) throws Throwable
{
if(mi.getMethod().getName().equals("createSnapshot"))
if (enableIndexing)
{
String store = (String)mi.getArguments()[0];
int before = avmService.getLatestSnapshotID(store);
Object returnValue = mi.proceed();
int after = avmService.getLatestSnapshotID(store);
StoreRef storeRef = AVMNodeConverter.ToStoreRef(store);
Indexer indexer = indexerAndSearcher.getIndexer(storeRef);
if(indexer instanceof AVMLuceneIndexer)
if (mi.getMethod().getName().equals("createSnapshot"))
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer)indexer;
avmIndexer.index(store, before, after);
String store = (String) mi.getArguments()[0];
int before = avmService.getLatestSnapshotID(store);
Object returnValue = mi.proceed();
int after = avmService.getLatestSnapshotID(store);
StoreRef storeRef = AVMNodeConverter.ToStoreRef(store);
Indexer indexer = indexerAndSearcher.getIndexer(storeRef);
if (indexer instanceof AVMLuceneIndexer)
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer) indexer;
avmIndexer.index(store, before, after);
}
return returnValue;
}
return returnValue;
}
// TODO: Purge store
else if(mi.getMethod().getName().equals("purgeStore"))
{
String store = (String)mi.getArguments()[0];
Object returnValue = mi.proceed();
StoreRef storeRef = AVMNodeConverter.ToStoreRef(store);
Indexer indexer = indexerAndSearcher.getIndexer(storeRef);
if(indexer instanceof AVMLuceneIndexer)
// TODO: Purge store
else if (mi.getMethod().getName().equals("purgeStore"))
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer)indexer;
avmIndexer.deleteIndex(store);
String store = (String) mi.getArguments()[0];
Object returnValue = mi.proceed();
StoreRef storeRef = AVMNodeConverter.ToStoreRef(store);
Indexer indexer = indexerAndSearcher.getIndexer(storeRef);
if (indexer instanceof AVMLuceneIndexer)
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer) indexer;
avmIndexer.deleteIndex(store);
}
return returnValue;
}
return returnValue;
}
else if(mi.getMethod().getName().equals("createStore"))
{
String store = (String)mi.getArguments()[0];
Object returnValue = mi.proceed();
StoreRef storeRef = AVMNodeConverter.ToStoreRef(store);
Indexer indexer = indexerAndSearcher.getIndexer(storeRef);
if(indexer instanceof AVMLuceneIndexer)
else if (mi.getMethod().getName().equals("createStore"))
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer)indexer;
avmIndexer.createIndex(store);
String store = (String) mi.getArguments()[0];
Object returnValue = mi.proceed();
StoreRef storeRef = AVMNodeConverter.ToStoreRef(store);
Indexer indexer = indexerAndSearcher.getIndexer(storeRef);
if (indexer instanceof AVMLuceneIndexer)
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer) indexer;
avmIndexer.createIndex(store);
}
return returnValue;
}
return returnValue;
}
else if(mi.getMethod().getName().equals("renameStore"))
{
String from = (String)mi.getArguments()[0];
String to = (String)mi.getArguments()[1];
Object returnValue = mi.proceed();
int after = avmService.getLatestSnapshotID(to);
StoreRef fromRef = AVMNodeConverter.ToStoreRef(from);
StoreRef toRef = AVMNodeConverter.ToStoreRef(to);
Indexer indexer = indexerAndSearcher.getIndexer(fromRef);
if(indexer instanceof AVMLuceneIndexer)
else if (mi.getMethod().getName().equals("renameStore"))
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer)indexer;
avmIndexer.deleteIndex(from);
String from = (String) mi.getArguments()[0];
String to = (String) mi.getArguments()[1];
Object returnValue = mi.proceed();
int after = avmService.getLatestSnapshotID(to);
StoreRef fromRef = AVMNodeConverter.ToStoreRef(from);
StoreRef toRef = AVMNodeConverter.ToStoreRef(to);
Indexer indexer = indexerAndSearcher.getIndexer(fromRef);
if (indexer instanceof AVMLuceneIndexer)
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer) indexer;
avmIndexer.deleteIndex(from);
}
indexer = indexerAndSearcher.getIndexer(toRef);
if (indexer instanceof AVMLuceneIndexer)
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer) indexer;
avmIndexer.createIndex(to);
avmIndexer.index(to, 0, after);
}
return returnValue;
}
indexer = indexerAndSearcher.getIndexer(toRef);
if(indexer instanceof AVMLuceneIndexer)
else
{
AVMLuceneIndexer avmIndexer = (AVMLuceneIndexer)indexer;
avmIndexer.createIndex(to);
avmIndexer.index(to, 0, after);
return mi.proceed();
}
return returnValue;
}
else
{
return mi.proceed();
}
}
/**
* Set the AVM service
*
* @param avmService
*/
public void setAvmService(AVMService avmService)
@@ -132,6 +140,7 @@ public class AVMSnapShotTriggeredIndexingMethodInterceptor implements MethodInte
/**
* Set the AVM indexer and searcher
*
* @param indexerAndSearcher
*/
public void setIndexerAndSearcher(IndexerAndSearcher indexerAndSearcher)
@@ -139,4 +148,16 @@ public class AVMSnapShotTriggeredIndexingMethodInterceptor implements MethodInte
this.indexerAndSearcher = indexerAndSearcher;
}
/**
* Enable or disable indexing
*
* @param enableIndexing
*/
public void setEnableIndexing(boolean enableIndexing)
{
this.enableIndexing = enableIndexing;
}
}