org.infinispan.query.indexmanager
Class MasterSwitchDelegatingQueueProcessor
java.lang.Object
org.infinispan.query.indexmanager.MasterSwitchDelegatingQueueProcessor
- All Implemented Interfaces:
- org.hibernate.search.backend.spi.BackendQueueProcessor
public class MasterSwitchDelegatingQueueProcessor
- extends Object
- implements org.hibernate.search.backend.spi.BackendQueueProcessor
Switches between local indexing by delegating to a traditional BackendQueueProcessor
or to the custom InfinispanCommandsBackend to delegate to remote nodes.
- Author:
- Sanne Grinovero
Method Summary |
void |
applyStreamWork(org.hibernate.search.backend.LuceneWork singleOperation,
org.hibernate.search.backend.IndexingMonitor monitor)
|
void |
applyWork(List<org.hibernate.search.backend.LuceneWork> workList,
org.hibernate.search.backend.IndexingMonitor monitor)
|
void |
close()
|
Lock |
getExclusiveWriteLock()
|
void |
indexMappingChanged()
|
void |
initialize(Properties props,
org.hibernate.search.spi.WorkerBuildContext context,
org.hibernate.search.indexes.impl.DirectoryBasedIndexManager indexManager)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MasterSwitchDelegatingQueueProcessor
public MasterSwitchDelegatingQueueProcessor(org.hibernate.search.backend.spi.BackendQueueProcessor localMaster,
InfinispanCommandsBackend remoteMaster)
initialize
public void initialize(Properties props,
org.hibernate.search.spi.WorkerBuildContext context,
org.hibernate.search.indexes.impl.DirectoryBasedIndexManager indexManager)
- Specified by:
initialize
in interface org.hibernate.search.backend.spi.BackendQueueProcessor
close
public void close()
- Specified by:
close
in interface org.hibernate.search.backend.spi.BackendQueueProcessor
applyWork
public void applyWork(List<org.hibernate.search.backend.LuceneWork> workList,
org.hibernate.search.backend.IndexingMonitor monitor)
- Specified by:
applyWork
in interface org.hibernate.search.backend.spi.BackendQueueProcessor
applyStreamWork
public void applyStreamWork(org.hibernate.search.backend.LuceneWork singleOperation,
org.hibernate.search.backend.IndexingMonitor monitor)
- Specified by:
applyStreamWork
in interface org.hibernate.search.backend.spi.BackendQueueProcessor
getExclusiveWriteLock
public Lock getExclusiveWriteLock()
- Specified by:
getExclusiveWriteLock
in interface org.hibernate.search.backend.spi.BackendQueueProcessor
indexMappingChanged
public void indexMappingChanged()
- Specified by:
indexMappingChanged
in interface org.hibernate.search.backend.spi.BackendQueueProcessor
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.