org.broadleafcommerce.common.util

Class StreamingTransactionCapableUtil

java.lang.Object

org.broadleafcommerce.common.util.StreamingTransactionCapableUtil

All Implemented Interfaces:

StreamingTransactionCapable

@Component(value="blStreamingTransactionCapableUtil")
@Scope(value="prototype")
public class StreamingTransactionCapableUtil
extends Object
implements StreamingTransactionCapable

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.persistence.EntityManager	em
protected int	pageSize
protected int	retryMax
protected org.springframework.transaction.PlatformTransactionManager	transactionManager

Constructor Summary

Constructors

Constructor and Description
StreamingTransactionCapableUtil()

Method Summary

Methods

Modifier and Type	Method and Description
protected <G extends Throwable> void	endTransaction(org.springframework.transaction.TransactionStatus status, boolean error, Class<G> exceptionType)
int	getPageSize()
int	getRetryMax()
org.springframework.transaction.PlatformTransactionManager	getTransactionManager()
void	init()
<G extends Throwable> void	runOptionalTransactionalOperation(StreamCapableTransactionalOperation operation, Class<G> exceptionType, boolean useTransaction)
<G extends Throwable> void	runOptionalTransactionalOperation(StreamCapableTransactionalOperation operation, Class<G> exceptionType, boolean useTransaction, int transactionBehavior, int isolationLevel)
<G extends Throwable> void	runStreamingTransactionalOperation(StreamCapableTransactionalOperation streamOperation, Class<G> exceptionType)
<G extends Throwable> void	runStreamingTransactionalOperation(StreamCapableTransactionalOperation streamOperation, Class<G> exceptionType, int transactionBehavior, int isolationLevel)
<G extends Throwable> void	runTransactionalOperation(StreamCapableTransactionalOperation operation, Class<G> exceptionType)
<G extends Throwable> void	runTransactionalOperation(StreamCapableTransactionalOperation operation, Class<G> exceptionType, int transactionBehavior, int isolationLevel)
void	setPageSize(int pageSize)
void	setRetryMax(int retryMax)
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
protected org.springframework.transaction.TransactionStatus	startTransaction(int propagationBehavior, int isolationLevel)

Methods inherited from class java.lang.Object

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

Field Detail

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

em

protected javax.persistence.EntityManager em

retryMax

@Value(value="${streaming.transaction.lock.retry.max}")
protected int retryMax

pageSize

@Value(value="${streaming.transaction.item.page.size}")
protected int pageSize

Constructor Detail

StreamingTransactionCapableUtil

public StreamingTransactionCapableUtil()

Method Detail

init

@PostConstruct
public void init()

runStreamingTransactionalOperation

public <G extends Throwable> void runStreamingTransactionalOperation(StreamCapableTransactionalOperation streamOperation,
                                                            Class<G> exceptionType)
                                        throws G extends Throwable

Specified by:

runStreamingTransactionalOperation in interface StreamingTransactionCapable

Throws:

G extends Throwable

runStreamingTransactionalOperation

public <G extends Throwable> void runStreamingTransactionalOperation(StreamCapableTransactionalOperation streamOperation,
                                                            Class<G> exceptionType,
                                                            int transactionBehavior,
                                                            int isolationLevel)
                                        throws G extends Throwable

Specified by:

runStreamingTransactionalOperation in interface StreamingTransactionCapable

Throws:

G extends Throwable

runTransactionalOperation

public <G extends Throwable> void runTransactionalOperation(StreamCapableTransactionalOperation operation,
                                                   Class<G> exceptionType)
                               throws G extends Throwable

Specified by:

runTransactionalOperation in interface StreamingTransactionCapable

Throws:

G extends Throwable

runTransactionalOperation

public <G extends Throwable> void runTransactionalOperation(StreamCapableTransactionalOperation operation,
                                                   Class<G> exceptionType,
                                                   int transactionBehavior,
                                                   int isolationLevel)
                               throws G extends Throwable

Specified by:

runTransactionalOperation in interface StreamingTransactionCapable

Throws:

G extends Throwable

runOptionalTransactionalOperation

public <G extends Throwable> void runOptionalTransactionalOperation(StreamCapableTransactionalOperation operation,
                                                           Class<G> exceptionType,
                                                           boolean useTransaction)
                                       throws G extends Throwable

Specified by:

runOptionalTransactionalOperation in interface StreamingTransactionCapable

Throws:

G extends Throwable

runOptionalTransactionalOperation

public <G extends Throwable> void runOptionalTransactionalOperation(StreamCapableTransactionalOperation operation,
                                                           Class<G> exceptionType,
                                                           boolean useTransaction,
                                                           int transactionBehavior,
                                                           int isolationLevel)
                                       throws G extends Throwable

Specified by:

runOptionalTransactionalOperation in interface StreamingTransactionCapable

Throws:

G extends Throwable

getPageSize

public int getPageSize()

Specified by:

getPageSize in interface StreamingTransactionCapable

setPageSize

public void setPageSize(int pageSize)

Specified by:

setPageSize in interface StreamingTransactionCapable

getTransactionManager

public org.springframework.transaction.PlatformTransactionManager getTransactionManager()

Specified by:

getTransactionManager in interface StreamingTransactionCapable

setTransactionManager

public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

Specified by:

setTransactionManager in interface StreamingTransactionCapable

getRetryMax

public int getRetryMax()

Specified by:

getRetryMax in interface StreamingTransactionCapable

setRetryMax

public void setRetryMax(int retryMax)

Specified by:

setRetryMax in interface StreamingTransactionCapable

endTransaction

protected <G extends Throwable> void endTransaction(org.springframework.transaction.TransactionStatus status,
                                        boolean error,
                                        Class<G> exceptionType)
                       throws G extends Throwable

Throws:

G extends Throwable

startTransaction

protected org.springframework.transaction.TransactionStatus startTransaction(int propagationBehavior,
                                                                 int isolationLevel)