Package org.broadleafcommerce.common.util

Class StreamCapableTransactionalOperationAdapter

java.lang.Object

org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

All Implemented Interfaces:

StreamCapableTransactionalOperation, TransactionalOperation

public abstract class StreamCapableTransactionalOperationAdapter
extends Object
implements StreamCapableTransactionalOperation

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field	Description
protected Object[]	pagedItems

Constructor Summary

Constructors

Constructor	Description
StreamCapableTransactionalOperationAdapter()

Method Summary

Modifier and Type	Method	Description
void	execute()
void	executeAfterCommit(Object[] param)
Object[]	getPagedItems()
void	pagedExecute(Object[] param)
Object[]	retrievePage(int startPos, int pageSize)
Long	retrieveTotalCount()
int	retryMaxCountOverrideForLockAcquisitionFailure()
void	setPagedItems(Object[] pagedItems)
boolean	shouldRetryOnTransactionLockAcquisitionFailure()

Methods inherited from class java.lang.Object

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

Field Details

pagedItems

protected Object[] pagedItems

Constructor Details

StreamCapableTransactionalOperationAdapter

public StreamCapableTransactionalOperationAdapter()

Method Details

pagedExecute

public void pagedExecute(Object[] param)
                  throws Throwable

Specified by:

pagedExecute in interface StreamCapableTransactionalOperation

Throws:

Throwable

executeAfterCommit

public void executeAfterCommit(Object[] param)

Specified by:

executeAfterCommit in interface StreamCapableTransactionalOperation

execute

public void execute()
             throws Throwable

Specified by:

execute in interface TransactionalOperation

Throws:

Throwable

retrievePage

public Object[] retrievePage(int startPos,
 int pageSize)

Specified by:

retrievePage in interface StreamCapableTransactionalOperation

retrieveTotalCount

public Long retrieveTotalCount()

Specified by:

retrieveTotalCount in interface StreamCapableTransactionalOperation

getPagedItems

public Object[] getPagedItems()

setPagedItems

public void setPagedItems(Object[] pagedItems)

shouldRetryOnTransactionLockAcquisitionFailure

public boolean shouldRetryOnTransactionLockAcquisitionFailure()

Specified by:

shouldRetryOnTransactionLockAcquisitionFailure in interface StreamCapableTransactionalOperation

retryMaxCountOverrideForLockAcquisitionFailure

public int retryMaxCountOverrideForLockAcquisitionFailure()

Specified by:

retryMaxCountOverrideForLockAcquisitionFailure in interface StreamCapableTransactionalOperation