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

Constructor Summary

Constructors

Constructor and Description
MasterSwitchDelegatingQueueProcessor(org.hibernate.search.backend.spi.BackendQueueProcessor localMaster, InfinispanCommandsBackend remoteMaster)

Method Summary

Methods

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

Constructor Detail

MasterSwitchDelegatingQueueProcessor

public MasterSwitchDelegatingQueueProcessor(org.hibernate.search.backend.spi.BackendQueueProcessor localMaster,
                                    InfinispanCommandsBackend remoteMaster)

Method Detail

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