org.compass.core.lucene.engine.transaction.async
Class AsyncTransactionProcessor

java.lang.Object
  extended by org.compass.core.lucene.engine.transaction.support.AbstractTransactionProcessor
      extended by org.compass.core.lucene.engine.transaction.support.AbstractSearchTransactionProcessor
          extended by org.compass.core.lucene.engine.transaction.support.AbstractJobBasedTransactionProcessor
              extended by org.compass.core.lucene.engine.transaction.async.AsyncTransactionProcessor
All Implemented Interfaces:
TransactionProcessor

public class AsyncTransactionProcessor
extends AbstractJobBasedTransactionProcessor

Processes transaction asynchronously. For more information see AsyncTransactionProcessorFactory.

Author:
kimchy
See Also:
AsyncTransactionProcessorFactory

Field Summary
 
Fields inherited from class org.compass.core.lucene.engine.transaction.support.AbstractTransactionProcessor
indexManager, mapping, searchEngine, searchEngineFactory
 
Constructor Summary
AsyncTransactionProcessor(LuceneSearchEngine searchEngine, AsyncTransactionProcessorFactory processorFactory)
          Constructs a new processor (for a given transaction) with a back reference to the AsyncTransactionProcessorFactory in order to add (at commit) the TransactionJobs.
 
Method Summary
protected  void doCommit(boolean onePhase, TransactionJobs jobs)
           
protected  void doFlushCommit(TransactionJobs jobs)
           
protected  void doPrepare(TransactionJobs jobs)
           
protected  void doRollback(TransactionJobs jobs)
           
 String getName()
          Retuns the name of this transaction processor.
 
Methods inherited from class org.compass.core.lucene.engine.transaction.support.AbstractJobBasedTransactionProcessor
begin, commit, create, delete, delete, find, flush, flushCommit, get, internalSearch, prepare, rollback, update
 
Methods inherited from class org.compass.core.lucene.engine.transaction.support.AbstractSearchTransactionProcessor
performFind, performGet, performInternalSearch
 
Methods inherited from class org.compass.core.lucene.engine.transaction.support.AbstractTransactionProcessor
buildInternalSearch, findByQuery, getResourceMapping, getSettingName, isInvalidateCacheOnCommit
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AsyncTransactionProcessor

public AsyncTransactionProcessor(LuceneSearchEngine searchEngine,
                                 AsyncTransactionProcessorFactory processorFactory)
Constructs a new processor (for a given transaction) with a back reference to the AsyncTransactionProcessorFactory in order to add (at commit) the TransactionJobs.

Method Detail

getName

public String getName()
Description copied from interface: TransactionProcessor
Retuns the name of this transaction processor.


doPrepare

protected void doPrepare(TransactionJobs jobs)
                  throws SearchEngineException
Specified by:
doPrepare in class AbstractJobBasedTransactionProcessor
Throws:
SearchEngineException

doFlushCommit

protected void doFlushCommit(TransactionJobs jobs)
Specified by:
doFlushCommit in class AbstractJobBasedTransactionProcessor

doCommit

protected void doCommit(boolean onePhase,
                        TransactionJobs jobs)
                 throws SearchEngineException
Specified by:
doCommit in class AbstractJobBasedTransactionProcessor
Throws:
SearchEngineException

doRollback

protected void doRollback(TransactionJobs jobs)
                   throws SearchEngineException
Specified by:
doRollback in class AbstractJobBasedTransactionProcessor
Throws:
SearchEngineException


Copyright (c) 2004-2009 The Compass Project.