com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

Class DefaultBatchTransactionContextFactory

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContextFactory

All Implemented Interfaces:

BatchTransactionContextFactory

public class DefaultBatchTransactionContextFactory
extends Object
implements BatchTransactionContextFactory

Default implementation of BatchTransactionContextFactory

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
DefaultBatchTransactionContextFactory(BatchEngine batchEngine)

Method Summary

Modifier and Type	Method and Description
void	closeAndRollback() closes this factory meaning that it will not accept requests to create any addiitional BatchTransactionContexts.
int	countOpenTransactions() For monitoring and testing purposes only
BatchTransactionContext	createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter
int	getTrackedContextsCount() For monitoring purposes

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBatchTransactionContextFactory

public DefaultBatchTransactionContextFactory(BatchEngine batchEngine)

Method Detail

getTrackedContextsCount

public int getTrackedContextsCount()

For monitoring purposes

Returns:

the amount of contexts being currently tracked

createTransactionContext

public BatchTransactionContext createTransactionContext(BatchJobInstanceAdapter jobInstance)

Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter

Specified by:

createTransactionContext in interface BatchTransactionContextFactory

Parameters:

jobInstance - a not null BatchJobInstanceAdapter

Returns:

a new BatchTransactionContext

closeAndRollback

public void closeAndRollback()

closes this factory meaning that it will not accept requests to create any addiitional BatchTransactionContexts. If BatchTransactionContextFactory.createTransactionContext(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter) is invoked after this method it will throw IllegalStateException. Any active transactions that hasn't been rolled back or commit at the moment of invoking this method will be automatically rolled back. This method is thread safe and can be safely invoked multiple times

Specified by:

closeAndRollback in interface BatchTransactionContextFactory

countOpenTransactions

public int countOpenTransactions()

Description copied from interface: BatchTransactionContextFactory

For monitoring and testing purposes only

Specified by:

countOpenTransactions in interface BatchTransactionContextFactory

Returns:

how many BatchTransactionContext instances have been created but not closed yet