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 and Description
protected Object[]	pagedItems

Constructor Summary

Constructors

Constructor and Description
StreamCapableTransactionalOperationAdapter()

Method Summary

Modifier and Type	Method and 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 Detail

pagedItems

protected Object[] pagedItems

Constructor Detail

StreamCapableTransactionalOperationAdapter

public StreamCapableTransactionalOperationAdapter()

Method Detail

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