Uses of Interface
com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Packages that use BatchTransactionContext

Package	Description
com.mulesoft.mule.runtime.module.batch
com.mulesoft.mule.runtime.module.batch.engine
com.mulesoft.mule.runtime.module.batch.engine.buffer
com.mulesoft.mule.runtime.module.batch.engine.queue
com.mulesoft.mule.runtime.module.batch.engine.transaction
com.mulesoft.mule.runtime.module.batch.internal
com.mulesoft.mule.runtime.module.batch.internal.engine
com.mulesoft.mule.runtime.module.batch.internal.engine.buffer
com.mulesoft.mule.runtime.module.batch.internal.engine.queue
com.mulesoft.mule.runtime.module.batch.internal.engine.threading
com.mulesoft.mule.runtime.module.batch.internal.engine.transaction
com.mulesoft.mule.runtime.module.batch.util

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch

Methods in com.mulesoft.mule.runtime.module.batch with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
int	BatchStepAggregator.add(Record record, BatchTransactionContext ctx) Adds a new record

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.engine

Methods in com.mulesoft.mule.runtime.module.batch.engine that return BatchTransactionContext

Modifier and Type	Method and Description
BatchTransactionContext	BatchEngine.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates a new BatchTransactionContext referencing the given {@link BatchJobInstanceAdapter}

Methods in com.mulesoft.mule.runtime.module.batch.engine with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
boolean	BatchStepAdapter.finishIfCompleted(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx) If the step has processed all the records for the given BatchJobInstanceAdapter, then it fires a BatchNotification.STEP_JOB_END notification and flushes the step's commit (if any)
List<Record>	BatchEngine.getBlockFrom(BatchTransactionContext context) Returns the records in the stepping queue which corresponds to the BatchJobInstance referenced by the given context
long	BatchEngine.getSteppingQueueSize(BatchTransactionContext context) Deprecated. on 4.3.0, use BatchEngine.getBlockFrom(BatchTransactionContext)
Record	BatchStepAdapter.onRecord(Record record, BatchTransactionContext ctx) Process the given Record for the given BatchJobInstanceAdapter
BatchJobInstanceAdapter	BatchEngine.updateStatisticsAndRoute(BatchTransactionContext ctx, List<Record> records)

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.engine.buffer

Methods in com.mulesoft.mule.runtime.module.batch.engine.buffer with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
void	BatchContextTransactionManager.commit(BatchTransactionContext context) commit
void	BatchContextTransactionManager.rollback(BatchTransactionContext context, BatchJobInstanceAdapter jobInstance, List<Record> records, org.mule.runtime.api.exception.MuleException e) rollback

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.engine.queue

Methods in com.mulesoft.mule.runtime.module.batch.engine.queue with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
void	BatchQueueDelegate.dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	BatchQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager committer) Writes the given records into the queue and commits the transaction
void	BatchQueueDelegate.dispose(BatchTransactionContext ctx) Disposes the underlying Queues for the given BatchJobInstanceAdapter
void	BatchQueueManager.disposeQueues(BatchTransactionContext ctx) Disposes all initialized queues associated to the given BatchJobInstanceAdapter
Iterator<List<Record>>	BatchQueueDelegate.iterator(BatchTransactionContext ctx) Returns a streaming Iterator to access the contents of the queue.
List<Record>	BatchQueueDelegate.poll(BatchTransactionContext ctx) Retrieves a block of Record
long	BatchQueueDelegate.size(BatchTransactionContext ctx) Returns the size of the underlying queue

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.engine.transaction

Methods in com.mulesoft.mule.runtime.module.batch.engine.transaction that return BatchTransactionContext

Modifier and Type	Method and Description
BatchTransactionContext	BatchTransactionContextFactory.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.internal

Methods in com.mulesoft.mule.runtime.module.batch.internal with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
int	DefaultBatchStepAggregator.add(Record record, BatchTransactionContext ctx)
boolean	DefaultBatchStep.finishIfCompleted(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx) If the step has processed all the records for the given BatchJobInstanceAdapter, then it fires a BatchNotification.STEP_JOB_END notification and flushes the step's commit (if any)
Record	DefaultBatchStep.onRecord(Record record, BatchTransactionContext ctx) Process the given Record for the given BatchJobInstanceAdapter

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.internal.engine

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine that return BatchTransactionContext

Modifier and Type	Method and Description
BatchTransactionContext	DefaultBatchEngine.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates a new BatchTransactionContext referencing the given {@link BatchJobInstanceAdapter}

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
List<Record>	DefaultBatchEngine.getBlockFrom(BatchTransactionContext context)
long	DefaultBatchEngine.getSteppingQueueSize(BatchTransactionContext context)
BatchJobInstanceAdapter	DefaultBatchEngine.updateStatisticsAndRoute(BatchTransactionContext ctx, List<Record> records)

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
int	TransactionalQueueBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record) buffers the given Record for the given BatchJobInstanceAdapter
int	RecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record) buffers the given Record for the given BatchJobInstanceAdapter
int	InMemoryRecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record) buffers the given Record for the given BatchJobInstanceAdapter
int	StreamingAggregatorBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record)
static int	BufferUtils.addToBufferInSplitTransaction(BatchJobInstanceAdapter jobInstance, RecordBuffer buffer, BatchTransactionContext currentContext, BatchTransactionContextProvider contexts, Record record) Adds a record to the given buffer using a transaction other than the current one.
void	TransactionalQueueBuffer.commit(BatchTransactionContext context)
protected void	TransactionalQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
protected void	StreamingAggregatorInputQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
void	TransactionalQueueBuffer.rollback(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, org.mule.runtime.api.exception.MuleException e)
void	BatchContextTransactionRecorder.tryFlush(BatchTransactionContext ctx, List<Record> records) Attempts to flush records and update statistics.

Method parameters in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer with type arguments of type BatchTransactionContext

Modifier and Type	Method and Description
protected org.mule.runtime.core.api.event.CoreEvent	FixedAggregatorTransactionRecordBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected org.mule.runtime.core.api.event.CoreEvent	StreamingAggregatorBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected org.mule.runtime.core.api.event.CoreEvent	FixedAggregatorRecordBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected abstract org.mule.runtime.core.api.event.CoreEvent	AggregatorRecordBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Configures the event (set payload, properties, etc) to is going to be used when flushing the aggregated records through the AggregatorRecordBuffer.chain
protected abstract void	InMemoryRecordBuffer.doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Implement this logic to perform specific flushing logic
protected void	LoadingQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected void	AggregatorRecordBuffer.doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Executes the template returned by AggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap, Processor, MuleContext) using the CoreEvent returned by AggregatorRecordBuffer.configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap)
protected BatchProcessingTemplate	FixedAggregatorTransactionRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> contexts, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext)
protected BatchProcessingTemplate	StreamingAggregatorBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> records, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext)
protected BatchProcessingTemplate	FixedAggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> contexts, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext)
protected abstract BatchProcessingTemplate	AggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> records, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext) Returns the BatchProcessingTemplate through which AggregatorRecordBuffer.chain will be executed

Constructors in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer with parameters of type BatchTransactionContext

Constructor and Description
StreamingAggregatorIteratorWrapper(Iterator<List<Record>> delegate, BatchTransactionContextProvider outputContextProvider, BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, RecordBuffer outputQueueBuffer, int blockSize)

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.queue with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
void	SteppingQueueDelegate.dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	AbstractBatchQueueDelegate.dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	SteppingQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager manager)
void	AbstractBatchQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager manager)
void	AbstractBatchQueueDelegate.dispose(BatchTransactionContext ctx) Disposes the underlying Queues for the given BatchJobInstanceAdapter
void	DefaultBatchQueueManager.disposeQueues(BatchTransactionContext ctx) Disposes all initialized queues associated to the given BatchJobInstanceAdapter
Iterator<List<Record>>	AbstractBatchQueueDelegate.iterator(BatchTransactionContext ctx)
List<Record>	AbstractBatchQueueDelegate.poll(BatchTransactionContext ctx) Retrieves a block of Record
long	AbstractBatchQueueDelegate.size(BatchTransactionContext ctx) Returns the size of the underlying queue

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.internal.engine.threading

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.threading with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
void	DefaultBatchWorkManager.scheduleRecordWork(BatchTransactionContext ctx, Runnable work) Schedules the given work to be executed.
void	BatchWorkManager.scheduleRecordWork(BatchTransactionContext ctx, Runnable work) Schedules the given work to be executed.

Constructors in com.mulesoft.mule.runtime.module.batch.internal.engine.threading with parameters of type BatchTransactionContext

Constructor and Description
BatchRecordWork(BatchEngine batchEngine, BatchJobAdapter job, BatchTransactionContext ctx, BatchProcessingListener listener, List<Record> block)

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

Classes in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction that implement BatchTransactionContext

Modifier and Type	Class and Description
class	BaseBatchTransactionContextWrapper Base implementation of the decorator design pattern for instances of BatchTransactionContext This implementation delegates all of its methods into a delegate received in the constructor, including BaseBatchTransactionContextWrapper.equals(Object) and BaseBatchTransactionContextWrapper.hashCode().
class	DefaultBatchTransactionContext Default implementation of BatchTransactionContext

Fields in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction declared as BatchTransactionContext

Modifier and Type	Field and Description
protected BatchTransactionContext	BaseBatchTransactionContextWrapper.delegate

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction that return BatchTransactionContext

Modifier and Type	Method and Description
BatchTransactionContext	DefaultBatchTransactionContextFactory.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter
BatchTransactionContext	ManagedBatchTransactionContextProvider.get(BatchJobInstanceAdapter jobInstance) Returns a BatchTransactionContext for the given BatchJobInstanceAdapter
BatchTransactionContext	BatchTransactionContextProvider.get(BatchJobInstanceAdapter jobInstance) Returns a BatchTransactionContext for the given BatchJobInstanceAdapter

Constructors in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction with parameters of type BatchTransactionContext

Constructor and Description
BaseBatchTransactionContextWrapper(BatchTransactionContext delegate)

Uses of BatchTransactionContext in com.mulesoft.mule.runtime.module.batch.util

Methods in com.mulesoft.mule.runtime.module.batch.util with parameters of type BatchTransactionContext

Modifier and Type	Method and Description
static void	BatchUtils.commit(BatchTransactionContext ctx)
static void	BatchUtils.completeWorkOnBlock(List<Record> block, boolean shouldRollback, BatchProcessingListener listener, BatchTransactionContext ctx) Perform the completion callback for each record in the block as well as any further completion operation needed related to the transaction context.
static void	BatchUtils.rollback(BatchTransactionContext ctx)
static void	BatchUtils.singleAckAndCommitIfNecessary(BatchTransactionContext ctx)