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>	bind(List<RequestDocument> requestDocuments, String operation)
List<ResponseDocument>	checkIn(List<RequestDocument> requestDocuments)
ResponseDocument	checkIn(RequestDocument requestDocument)
List<ResponseDocument>	checkOut(List<RequestDocument> requestDocuments, String user)
void	close()
void	closeSession()
void	commit()
void	commit(BatchIngestStatistics batchIngestStatistics)
List<ResponseDocument>	delete(List<RequestDocument> requestDocuments)
List<ResponseDocument>	deleteVerify(List<RequestDocument> requestDocuments)
IndexerService	getIndexerService()
List<ResponseDocument>	ingest(List<RequestDocument> requestDocuments)
ResponseDocument	ingest(RequestDocument requestDocument)
void	setIndexerService(IndexerService indexerService)
void	startSession(String user, String operation)
void	startTransaction(String user, String operation)
void	transferInstances(List<RequestDocument> requestDocuments)
void	transferItems(List<RequestDocument> requestDocuments)
List<ResponseDocument>	unbind(List<RequestDocument> requestDocuments, 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

startSession

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

Throws:

OleDocStoreException

closeSession

public void closeSession()

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)
                               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

bind

public List<ResponseDocument> bind(List<RequestDocument> requestDocuments,
                                   String operation)
                            throws Exception,
                                   javax.jcr.RepositoryException,
                                   OleException,
                                   FileNotFoundException

Throws:

Exception

javax.jcr.RepositoryException

OleException

FileNotFoundException

unbind

public List<ResponseDocument> unbind(List<RequestDocument> requestDocuments,
                                     String operation)
                              throws Exception,
                                     javax.jcr.RepositoryException,
                                     OleException,
                                     FileNotFoundException

Throws:

Exception

javax.jcr.RepositoryException

OleException

FileNotFoundException

batchIngest

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

Throws:

OleDocStoreException

delete

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

Throws:

Exception

deleteVerify

public List<ResponseDocument> deleteVerify(List<RequestDocument> requestDocuments)
                                    throws Exception

Throws:

Exception

getIndexerService

public IndexerService getIndexerService()

setIndexerService

public void setIndexerService(IndexerService indexerService)

transferInstances

public void transferInstances(List<RequestDocument> requestDocuments)
                       throws Exception

Throws:

Exception

transferItems

public void transferItems(List<RequestDocument> requestDocuments)
                   throws Exception

Throws:

Exception