Uses of Interface
com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter

Packages that use BatchJobInstanceAdapter

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.reporting
com.mulesoft.mule.runtime.module.batch.util

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

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

Modifier and Type	Method and Description
void	BatchStepAggregator.flush(BatchJobInstanceAdapter jobInstance) Flushes the buffered Records for the given BatchJobInstanceAdapter.
void	BatchProcessingListener.onExecutableStateTransition(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter transitioned into an executable state
void	BatchProcessingListener.onJobFinished(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter has been finished
void	BatchProcessingListener.onJobInstanceStateChange(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter transitioned into a different BatchJobInstanceStatus
void	BatchProcessingListener.onJobStopped(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter has been stopped before completely finishing
void	BatchProcessingListener.onSteppingQueueDispatch(BatchJobInstanceAdapter jobInstance, Collection<Record> records) Notifies that the given Records were queued into the stepping queue of the given BatchJobInstanceAdapter
void	BatchStepAggregator.releaseResources(BatchJobInstanceAdapter jobInstance) Use this method when processing for the given BatchJobInstanceAdapter should stop and thus any allocated resources related to it should be freed.
long	BatchStepAggregator.size(BatchJobInstanceAdapter jobInstance)

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

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

Modifier and Type	Method and Description
BatchJobInstanceAdapter	BatchEngine.createNewJobInstance(BatchJobAdapter job, org.mule.runtime.core.api.event.CoreEvent event) Creates and initialises a new BatchJobInstanceAdapter related to the given job.
BatchJobInstanceAdapter	BatchEngine.finishExecution(BatchJobInstanceAdapter jobInstance, boolean shouldRefresh) Ends the execution of the given jobInstance
BatchJobInstanceAdapter	BatchJobInstanceStore.getJobInstance(String jobName, String jobInstanceId) Returns the BatchJobInstanceAdapter for the given job and id
BatchJobInstanceAdapter	BatchEngine.load(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent muleEvent) Splits the CoreEvent payload and loads it into the BatchJobInstanceAdapter queue.
BatchJobInstanceAdapter	BatchEngine.updateStatisticsAndRoute(BatchTransactionContext ctx, List<Record> records)

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

Modifier and Type	Method and Description
void	BatchEngine.cancel(BatchJobInstanceAdapter jobInstance) Stops the jobInstance if it's executing (by delegating into BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean).
void	BatchJobInstanceStore.clearFailedRecords(BatchJobInstanceAdapter jobInstance) Removes all the failed records records stored for the given BatchJobAdapter
org.mule.runtime.core.api.event.CoreEvent.Builder	BatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
org.mule.runtime.core.api.event.CoreEvent.Builder	BatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance, CompletableFuture<Void> externalCompletion) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
BatchTransactionContext	BatchEngine.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates a new BatchTransactionContext referencing the given {@link BatchJobInstanceAdapter}
BatchJobInstanceAdapter	BatchEngine.finishExecution(BatchJobInstanceAdapter jobInstance, boolean shouldRefresh) Ends the execution of the given jobInstance
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)
ExceptionHistory	BatchStepAdapter.getExceptionHistory(BatchJobInstanceAdapter jobInstance) Returns the ExceptionHistory associated to the given BatchJobInstanceAdapter
Iterator<Record>	BatchJobInstanceStore.getFailedRecords(BatchJobInstanceAdapter jobInstance) Retrieves all the records of the given BatchJobInstanceAdapter that failed in at least one step and which execution has finished
Lock	BatchEngine.getLock(BatchJobInstanceAdapter jobInstance) Obtains a Lock for the given jobInstance.
BatchJobInstanceAdapter	BatchEngine.load(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent muleEvent) Splits the CoreEvent payload and loads it into the BatchJobInstanceAdapter queue.
void	BatchStepAdapter.releaseResources(BatchJobInstanceAdapter jobInstance) Releases any resources that the step has allocated for the given jobInstance, such as ExceptionHistory, AggregatorRecordBuffer, etc.
void	BatchEngine.releaseResources(BatchJobInstanceAdapter jobInstance, boolean includeFailedRecords) Releases the resources still allocated to the given BatchJobInstanceAdapter, including queues and storage
void	BatchEngine.resumeExecution(BatchJobInstanceAdapter jobInstance) Resumes execution of a BatchJobInstance which was stopped through the BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean) method.
void	BatchEngine.startExecution(BatchJobInstanceAdapter jobInstance) Starts asynchronous execution of the given BatchJobInstanceAdapter.
void	BatchEngine.stopExecution(BatchJobInstanceAdapter jobInstance, boolean markAsFailed) Stops the execution of the given BatchJobInstanceAdapter.
void	BatchJobInstanceStore.store(BatchJobInstanceAdapter jobInstance) Stores the given job instance
void	BatchJobInstanceStore.storeFailedRecords(BatchJobInstanceAdapter jobInstance, Collection<Record> record) Adds the given Records to the list of failed records
void	BatchJobInstanceStore.update(BatchJobInstanceAdapter jobInstance) updates the given job instance.

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

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

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

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

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

Modifier and Type	Method and Description
void	BatchQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager committer) Writes the given records into the queue and commits the transaction
void	BatchQueueManager.disposeBroker(BatchJobInstanceAdapter jobInstance) Disposes just the broker for the queues.
BatchQueueDelegate	BatchQueueManager.steppingQueue(BatchJobInstanceAdapter jobInstance) Stepping queues are the ones used to move a Record from one BatchStep to the next.
BatchQueueDelegate	BatchQueueManager.streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance, BatchStepAdapter step) Returns a BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator
BatchQueueDelegate	BatchQueueManager.streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance, BatchStepAdapter step) Returns a BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator

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

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

Modifier and Type	Method and Description
BatchJobInstanceAdapter	BatchTransactionContext.getJobInstance() Returns the BatchJobInstanceAdapter for which this context was built

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

Modifier and Type	Method and Description
BatchTransactionContext	BatchTransactionContextFactory.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter
void	BatchTransactionContext.updateJobInstance(BatchJobInstanceAdapter jobInstance) Refreshes the state of the related BatchJobInstanceAdapter

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

Classes in com.mulesoft.mule.runtime.module.batch.internal that implement BatchJobInstanceAdapter

Modifier and Type	Class and Description
class	DefaultBatchJobInstance

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

Modifier and Type	Method and Description
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)
void	DefaultBatchStepAggregator.flush(BatchJobInstanceAdapter jobInstance)
ExceptionHistory	DefaultBatchStep.getExceptionHistory(BatchJobInstanceAdapter jobInstance)
void	BaseBatchProcessingListener.onExecutableStateTransition(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter transitioned into an executable state
void	BaseBatchProcessingListener.onJobFinished(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter has been finished
void	BaseBatchProcessingListener.onJobInstanceStateChange(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter transitioned into a different BatchJobInstanceStatus
void	BaseBatchProcessingListener.onJobStopped(BatchJobInstanceAdapter jobInstance) Notifies that the given BatchJobInstanceAdapter has been stopped before completely finishing
void	BaseBatchProcessingListener.onSteppingQueueDispatch(BatchJobInstanceAdapter jobInstance, Collection<Record> records) Notifies that the given Records were queued into the stepping queue of the given BatchJobInstanceAdapter
void	DefaultBatchStep.releaseResources(BatchJobInstanceAdapter jobInstance)
void	DefaultBatchStepAggregator.releaseResources(BatchJobInstanceAdapter jobInstance)
long	DefaultBatchStepAggregator.size(BatchJobInstanceAdapter jobInstance)

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

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

Modifier and Type	Method and Description
BatchJobInstanceAdapter	DefaultBatchEngine.createNewJobInstance(BatchJobAdapter job, org.mule.runtime.core.api.event.CoreEvent event) Creates and initialises a new BatchJobInstanceAdapter related to the given job.
BatchJobInstanceAdapter	DefaultBatchEngine.finishExecution(BatchJobInstanceAdapter jobInstance, boolean shouldRefresh) Finishes execution of the BatchJobInstanceAdapter in a successful way and makes it no longer eligible for execution by the steps.
BatchJobInstanceAdapter	DefaultBatchJobInstanceStore.getJobInstance(String jobName, String jobInstanceId) Returns the BatchJobInstanceAdapter for the given job and id
BatchJobInstanceAdapter	DefaultBatchEngine.load(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent event) Splits the CoreEvent payload and loads it into the BatchJobInstanceAdapter queue.
BatchJobInstanceAdapter	DefaultBatchEngine.updateStatisticsAndRoute(BatchTransactionContext ctx, List<Record> records)

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine that return types with arguments of type BatchJobInstanceAdapter

Modifier and Type	Method and Description
List<BatchJobInstanceAdapter>	DefaultBatchJobInstanceStore.getExecutingInstances() Retrieves all the BatchJobInstance that are currently elegible for execution.

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

Modifier and Type	Method and Description
protected void	BatchProcessingTemplate.before(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent event) This method is invoked right before each execution of BatchProcessingTemplate.messageProcessor.
void	DefaultBatchEngine.cancel(BatchJobInstanceAdapter jobInstance) Stops the jobInstance if it's executing (by delegating into BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean).
void	DefaultBatchJobInstanceStore.clearFailedRecords(BatchJobInstanceAdapter jobInstance) Removes all the failed records records stored for the given BatchJobAdapter
org.mule.runtime.core.api.event.CoreEvent.Builder	DefaultBatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
org.mule.runtime.core.api.event.CoreEvent.Builder	DefaultBatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance, CompletableFuture<Void> externalCompletion) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
BatchTransactionContext	DefaultBatchEngine.createTransactionContext(BatchJobInstanceAdapter jobInstance) Creates a new BatchTransactionContext referencing the given {@link BatchJobInstanceAdapter}
BatchJobInstanceAdapter	DefaultBatchEngine.finishExecution(BatchJobInstanceAdapter jobInstance, boolean shouldRefresh) Finishes execution of the BatchJobInstanceAdapter in a successful way and makes it no longer eligible for execution by the steps.
Iterator<Record>	DefaultBatchJobInstanceStore.getFailedRecords(BatchJobInstanceAdapter jobInstance)
Lock	DefaultBatchEngine.getLock(BatchJobInstanceAdapter jobInstance) Obtains a Lock for the given jobInstance.
protected void	BatchProcessingTemplate.handleException(BatchJobInstanceAdapter jobInstance, Exception e, org.mule.runtime.core.api.event.CoreEvent event)
protected void	BatchProcessingTemplate.handleSuccess(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent resultEvent, org.mule.runtime.core.api.event.CoreEvent.Builder builder)
BatchJobInstanceAdapter	DefaultBatchEngine.load(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent event) Splits the CoreEvent payload and loads it into the BatchJobInstanceAdapter queue.
protected abstract void	BatchProcessingTemplate.onException(BatchJobInstanceAdapter jobInstance, Exception e, org.mule.runtime.core.api.event.CoreEvent event) This method is invoked when the execution of BatchProcessingTemplate.messageProcessor throws exception or the result event carries a ExceptionPayload
protected void	BatchProcessingTemplate.onFinally(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent originalEvent, org.mule.runtime.core.api.event.CoreEvent resultEvent) This method is invoked when each execution of BatchProcessingTemplate.messageProcessor completes, no matter if was successful or not.
protected abstract void	BatchProcessingTemplate.onSuccess(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent responseEvent) This method is invoked when BatchProcessingTemplate.messageProcessor is execute without any exceptions
org.mule.runtime.core.api.event.CoreEvent	BatchProcessingTemplate.process(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent event) Executes the BatchProcessingTemplate.messageProcessor provided in the constructor with the given payload.
void	DefaultBatchEngine.releaseResources(BatchJobInstanceAdapter jobInstance, boolean includeFailedRecords) Releases the resources still allocated to the given BatchJobInstanceAdapter, including queues and storage
void	DefaultBatchEngine.resumeExecution(BatchJobInstanceAdapter jobInstance) Resumes execution of a BatchJobInstance which was stopped through the BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean) method.
void	DefaultBatchEngine.startExecution(BatchJobInstanceAdapter jobInstance) Starts asynchronous execution of the given BatchJobInstanceAdapter.
void	DefaultBatchEngine.stopExecution(BatchJobInstanceAdapter jobInstanceAdapter, boolean markAsFailed) Stops the execution of the given BatchJobInstanceAdapter.
void	DefaultBatchJobInstanceStore.store(BatchJobInstanceAdapter jobInstance) Stores the given job instance
void	DefaultBatchJobInstanceStore.storeFailedRecords(BatchJobInstanceAdapter jobInstance, Collection<Record> records) Adds the given Records to the list of failed records
void	DefaultBatchJobInstanceStore.update(BatchJobInstanceAdapter jobInstance) updates the given job instance.

Uses of BatchJobInstanceAdapter 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 BatchJobInstanceAdapter

Modifier and Type	Method and Description
int	RecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContextProvider ctxProvider, Record record) Invokes RecordBuffer.add(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, Record) using the BatchTransactionContext returned by the context provider
int	AbstractRecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContextProvider ctxProvider, Record record) Invokes RecordBuffer.add(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, Record) using the BatchTransactionContext returned by the context provider
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.
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 void	TransactionalQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
protected void	StreamingAggregatorInputQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
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 void	TransactionalQueueBuffer.doForget(BatchJobInstanceAdapter jobInstance)
protected void	StreamingAggregatorInputQueueBuffer.doForget(BatchJobInstanceAdapter jobInstance)
void	TransactionalQueueBuffer.flush(BatchJobInstanceAdapter jobInstance) Flushes the buffered Records for the given BatchJobInstanceAdapter.
void	RecordBuffer.flush(BatchJobInstanceAdapter jobInstance) Flushes the buffered Records for the given BatchJobInstanceAdapter.
void	InMemoryRecordBuffer.flush(BatchJobInstanceAdapter jobInstance) Flushes the buffered Records for the given BatchJobInstanceAdapter.
void	StreamingAggregatorBuffer.flush(BatchJobInstanceAdapter jobInstance)
void	TransactionalQueueBuffer.flushAndForget(BatchJobInstanceAdapter jobInstance) Atomically performs a RecordBuffer.flush(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter) followed by a RecordBuffer.forget(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter).
void	RecordBuffer.flushAndForget(BatchJobInstanceAdapter jobInstance) Atomically performs a RecordBuffer.flush(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter) followed by a RecordBuffer.forget(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter).
void	FixedAggregatorTransactionRecordBuffer.flushAndForget(BatchJobInstanceAdapter jobInstance)
void	InMemoryRecordBuffer.flushAndForget(BatchJobInstanceAdapter jobInstance) Atomically performs a InMemoryRecordBuffer.flush(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter) followed by a InMemoryRecordBuffer.forget(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter).
void	StreamingAggregatorBuffer.flushAndForget(BatchJobInstanceAdapter jobInstance)
void	BatchContextTransactionRecorder.flushAndForget(BatchJobInstanceAdapter jobInstance) Flushes all the records corresponding to the batch context for the job instance.
void	TransactionalQueueBuffer.forget(BatchJobInstanceAdapter jobInstance) Releases all tracking information for the given BatchJobInstanceAdapter
void	RecordBuffer.forget(BatchJobInstanceAdapter jobInstance) Releases all tracking information for the given BatchJobInstanceAdapter
void	FixedAggregatorTransactionRecordBuffer.forget(BatchJobInstanceAdapter jobInstance) For this implementation, to forget means to flush whatever records are currently buffered.
void	InMemoryRecordBuffer.forget(BatchJobInstanceAdapter jobInstance) Releases all tracking information for the given BatchJobInstanceAdapter
void	StreamingAggregatorBuffer.forget(BatchJobInstanceAdapter jobInstance)
void	FixedAggregatorRecordBuffer.forget(BatchJobInstanceAdapter jobInstance) For this implementation, to forget means to flush whatever records are currently buffered.
protected BatchQueueDelegate	StreamingAggregatorOutputQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance)
protected abstract BatchQueueDelegate	TransactionalQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance) Returns the BatchQueueDelegate through which information will be written into the queue
protected BatchQueueDelegate	SteppingQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance) Returns a BatchQueueDelegate for stepping queues returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)
protected BatchQueueDelegate	StreamingAggregatorInputQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance) Returns a BatchQueueDelegate for streaming aggregator queues
protected void	AggregatorRecordBuffer.markError(BatchJobInstanceAdapter jobInstance, List<Record> records, Exception e) Sets the records as failed in this step
void	TransactionalQueueBuffer.rollback(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, org.mule.runtime.api.exception.MuleException e)
long	TransactionalQueueBuffer.size(BatchJobInstanceAdapter jobInstance) Returns how many records are buffered for the given BatchJobInstanceAdapter
long	RecordBuffer.size(BatchJobInstanceAdapter jobInstance) Returns how many records are buffered for the given BatchJobInstanceAdapter
long	FixedAggregatorTransactionRecordBuffer.size(BatchJobInstanceAdapter jobInstance)
long	InMemoryRecordBuffer.size(BatchJobInstanceAdapter jobInstance) Returns how many records are buffered for the given BatchJobInstanceAdapter
long	StreamingAggregatorBuffer.size(BatchJobInstanceAdapter jobInstance)
Integer	BatchContextTransactionRecorder.size(BatchJobInstanceAdapter jobInstance) Returns the size of the not flushed records.

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

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

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

Fields in com.mulesoft.mule.runtime.module.batch.internal.engine.queue declared as BatchJobInstanceAdapter

Modifier and Type	Field and Description
protected BatchJobInstanceAdapter	AbstractBatchQueueDelegate.jobInstance

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

Modifier and Type	Method and Description
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	DefaultBatchQueueManager.disposeBroker(BatchJobInstanceAdapter jobInstance) Disposes just the broker for the queues.
long	BatchQueueLoader.splitAndLoad(BatchJob job, BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.event.CoreEvent event)
BatchQueueDelegate	DefaultBatchQueueManager.steppingQueue(BatchJobInstanceAdapter jobInstance) Stepping queues are the ones used to move a Record from one BatchStep to the next.
BatchQueueDelegate	DefaultBatchQueueManager.streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance, BatchStepAdapter step) Returns a BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator
BatchQueueDelegate	DefaultBatchQueueManager.streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance, BatchStepAdapter step) Returns a BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator

Constructors in com.mulesoft.mule.runtime.module.batch.internal.engine.queue with parameters of type BatchJobInstanceAdapter

Constructor and Description
AbstractBatchQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext)
AbstractStreamingAggregatorQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, BatchStepAdapter step, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext)
SteppingQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext, List<BatchProcessingListener> listeners)
StreamingAggregatorInputQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, BatchStepAdapter step, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext)
StreamingAggregatorOutputQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, BatchStepAdapter step, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext)

Uses of BatchJobInstanceAdapter 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 BatchJobInstanceAdapter

Modifier and Type	Method and Description
void	DefaultBatchWorkManager.awaitStop(BatchJobInstanceAdapter jobInstance) Makes the given jobInstance no longer executable (further invocations to BatchWorkManager.scheduleRecordWork(BatchTransactionContext, Runnable) will fail, and also waits for the currently scheduled tasks to complete before returning
void	BatchWorkManager.awaitStop(BatchJobInstanceAdapter jobInstance) Makes the given jobInstance no longer executable (further invocations to BatchWorkManager.scheduleRecordWork(BatchTransactionContext, Runnable) will fail, and also waits for the currently scheduled tasks to complete before returning

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

Constructor and Description
BatchJobInstanceTerminatorWork(BatchEngine batchEngine, BatchJobInstanceAdapter jobInstance)

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

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

Modifier and Type	Method and Description
BatchJobInstanceAdapter	BaseBatchTransactionContextWrapper.getJobInstance()
BatchJobInstanceAdapter	DefaultBatchTransactionContext.getJobInstance() Returns the BatchJobInstanceAdapter for which this context was built

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

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
void	BaseBatchTransactionContextWrapper.updateJobInstance(BatchJobInstanceAdapter jobInstance)
void	DefaultBatchTransactionContext.updateJobInstance(BatchJobInstanceAdapter jobInstance) Refreshes the state of the related BatchJobInstanceAdapter

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

Constructor and Description
DefaultBatchTransactionContext(BatchJobAdapter job, BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueSession queueSession)

Uses of BatchJobInstanceAdapter in com.mulesoft.mule.runtime.module.batch.reporting

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

Modifier and Type	Method and Description
ExceptionHistory	StepExceptionReporter.getExceptionHistory(BatchJobInstanceAdapter jobInstance)
void	StepExceptionReporter.report(BatchJobInstanceAdapter jobInstance, Exception exception)
void	StepExceptionReporter.reset(BatchJobInstanceAdapter jobInstance)

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

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

Modifier and Type	Method and Description
static BatchException	BatchUtils.toBatchException(Exception e, BatchJobInstanceAdapter jobInstance)