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

protected javax.persistence.EntityManager	em
protected int	pageSize
protected org.springframework.transaction.PlatformTransactionManager	transactionManager

Constructor Summary

StreamingTransactionCapableUtil()

Method Summary

protected <G extends Throwable> void	endTransaction(org.springframework.transaction.TransactionStatus status, boolean error, Class<G> exceptionType)
int	getPageSize()
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	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

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

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)