org.kuali.ole.docstore.transaction
Class TransactionManager

java.lang.Object
  org.kuali.ole.docstore.transaction.TransactionManager

public class TransactionManager
extends Object

Encapsulates reusable common logic to support ACID transactions in DocStore. User: tirumalesh.b Date: 26/9/12 Time: 10:40 AM

Nested Class Summary

static class

TransactionManager.TransactionState

Constructor Summary

TransactionManager()

Method Summary

void	abort()
void	batchIngest(BulkProcessRequest bulkProcessRequest, List<RequestDocument> requestDocuments)
List<ResponseDocument>	checkIn(List<RequestDocument> requestDocuments, String operation)
ResponseDocument	checkIn(RequestDocument requestDocument)
List<ResponseDocument>	checkOut(List<RequestDocument> requestDocuments, String user)
void	close()
void	commit()
void	commit(BatchIngestStatistics batchIngestStatistics)
List<ResponseDocument>	delete(List<RequestDocument> requestDocuments)
IndexerService	getIndexerService()
List<ResponseDocument>	ingest(List<RequestDocument> requestDocuments)
ResponseDocument	ingest(RequestDocument requestDocument)
void	setIndexerService(IndexerService indexerService)
void	startTransaction(String user, String operation)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionManager

public TransactionManager()

Method Detail

startTransaction

public void startTransaction(String user,
                             String operation)
                      throws OleDocStoreException

Throws:

OleDocStoreException

commit

public void commit()
            throws OleDocStoreException

Throws:

OleDocStoreException

commit

public void commit(BatchIngestStatistics batchIngestStatistics)
            throws OleDocStoreException

Throws:

OleDocStoreException

abort

public void abort()

close

public void close()

ingest

public List<ResponseDocument> ingest(List<RequestDocument> requestDocuments)
                              throws OleDocStoreException

Throws:

OleDocStoreException

ingest

public ResponseDocument ingest(RequestDocument requestDocument)
                        throws OleDocStoreException

Throws:

OleDocStoreException

checkIn

public List<ResponseDocument> checkIn(List<RequestDocument> requestDocuments,
                                      String operation)
                               throws OleDocStoreException

Throws:

OleDocStoreException

checkOut

public List<ResponseDocument> checkOut(List<RequestDocument> requestDocuments,
                                       String user)
                                throws OleDocStoreException

Throws:

OleDocStoreException

checkIn

public ResponseDocument checkIn(RequestDocument requestDocument)
                         throws OleDocStoreException

Throws:

OleDocStoreException

batchIngest

public void batchIngest(BulkProcessRequest bulkProcessRequest,
                        List<RequestDocument> requestDocuments)
                 throws OleDocStoreException

Throws:

OleDocStoreException

delete

public List<ResponseDocument> delete(List<RequestDocument> requestDocuments)
                              throws OleDocStoreException

Throws:

OleDocStoreException

getIndexerService

public IndexerService getIndexerService()

setIndexerService

public void setIndexerService(IndexerService indexerService)