Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.query.indexmanager
Class MasterSwitchDelegatingQueueProcessor

java.lang.Object
  extended by 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
MasterSwitchDelegatingQueueProcessor(org.hibernate.search.backend.spi.BackendQueueProcessor localMaster, InfinispanCommandsBackend remoteMaster)
           
 
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
 

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

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.