com.broadleafcommerce.datafeed.generator

Class DataFeedStreamingOperation<T>

java.lang.Object

org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

com.broadleafcommerce.datafeed.generator.DataFeedStreamingOperation<T>

All Implemented Interfaces:

org.broadleafcommerce.common.util.StreamCapableTransactionalOperation, org.broadleafcommerce.common.util.TransactionalOperation

public class DataFeedStreamingOperation<T>
extends org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	LOG

Fields inherited from class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

pagedItems

Constructor Summary

Constructors

Constructor and Description
DataFeedStreamingOperation(DataFeed dataFeed, DataFeedPublisher publisher, AbstractStreamingDataFeedGenerator<T> generator)

Method Summary

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

Methods inherited from class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

execute, executeAfterCommit, getPagedItems, setPagedItems

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected final org.apache.commons.logging.Log LOG

Constructor Detail

DataFeedStreamingOperation

public DataFeedStreamingOperation(DataFeed dataFeed,
                                  DataFeedPublisher publisher,
                                  AbstractStreamingDataFeedGenerator<T> generator)

Method Detail

pagedExecute

public void pagedExecute(Object[] param)

Specified by:

pagedExecute in interface org.broadleafcommerce.common.util.StreamCapableTransactionalOperation

Overrides:

pagedExecute in class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

retrievePage

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

Specified by:

retrievePage in interface org.broadleafcommerce.common.util.StreamCapableTransactionalOperation

Overrides:

retrievePage in class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

retrieveTotalCount

public Long retrieveTotalCount()

Specified by:

retrieveTotalCount in interface org.broadleafcommerce.common.util.StreamCapableTransactionalOperation

Overrides:

retrieveTotalCount in class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

shouldRetryOnTransactionLockAcquisitionFailure

public boolean shouldRetryOnTransactionLockAcquisitionFailure()

Specified by:

shouldRetryOnTransactionLockAcquisitionFailure in interface org.broadleafcommerce.common.util.StreamCapableTransactionalOperation

Overrides:

shouldRetryOnTransactionLockAcquisitionFailure in class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter

retryMaxCountOverrideForLockAcquisitionFailure

public int retryMaxCountOverrideForLockAcquisitionFailure()

Specified by:

retryMaxCountOverrideForLockAcquisitionFailure in interface org.broadleafcommerce.common.util.StreamCapableTransactionalOperation

Overrides:

retryMaxCountOverrideForLockAcquisitionFailure in class org.broadleafcommerce.common.util.StreamCapableTransactionalOperationAdapter