A B C D E F G H I J L M N O P R S T U W

A

AbstractBatchQueueDelegate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Base class for implementation of BatchQueueDelegate

AbstractBatchQueueDelegate(BatchJobInstanceAdapter, QueueManager, long, ObjectSerializer, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

AbstractRecordBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Base implementation of RecordBuffer which implements basic functionality such as the NamedObject interface, carrying the MuleContext and other functionality

AbstractRecordBuffer(String) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

AbstractStreamingAggregatorQueueBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Base class for implementations of TransactionalQueueBuffer that rely on a BatchStep

AbstractStreamingAggregatorQueueBuffer(String, BatchEngine, BatchStepAdapter) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractStreamingAggregatorQueueBuffer

AbstractStreamingAggregatorQueueDelegate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Base class for implementations of AbstractBatchQueueDelegate which depends on a BatchStepAdapter

AbstractStreamingAggregatorQueueDelegate(BatchJobInstanceAdapter, QueueManager, long, BatchStepAdapter, ObjectSerializer, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractStreamingAggregatorQueueDelegate

acceptEither(CompletionStage<? extends Void>, Consumer<? super Void>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

acceptEitherAsync(CompletionStage<? extends Void>, Consumer<? super Void>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

acceptEitherAsync(CompletionStage<? extends Void>, Consumer<? super Void>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

acceptRecord(CoreEvent, Record) - Method in class com.mulesoft.mule.runtime.module.batch.internal.record.RecordFilteringStrategy

account(T) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchStepExceptionSummaryAdapter

Updates summary information with the given exception

account(T) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepExceptionSummary

Updates summary information with the given exception

ackProcessedRecords(int) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

reports that howMany records were successfully processed in this context (by successfully I mean without incidents.

ackProcessedRecords(int) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

ackProcessedRecords(int) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

reports that howMany records were successfully processed in this context (by successfully I mean without incidents.

ackSingleRecordProcessed() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

reports that one record has been successfully processed in this context (by successfully I mean without incidents.

ackSingleRecordProcessed() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

ackSingleRecordProcessed() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

reports that one record has been successfully processed in this context (by successfully I mean without incidents.

add(Record, BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

Adds a new record

add(Exception) - Method in class com.mulesoft.mule.runtime.module.batch.exception.ExceptionHistory

Adds the given exception to the history

add(Record, BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

add(BatchJobInstanceAdapter, BatchTransactionContextProvider, Record) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

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

add(BatchJobInstanceAdapter, BatchTransactionContext, Record) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

buffers the given Record for the given BatchJobInstanceAdapter

add(BatchJobInstanceAdapter, BatchTransactionContextProvider, Record) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

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

add(BatchJobInstanceAdapter, BatchTransactionContext, Record) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

buffers the given Record for the given BatchJobInstanceAdapter

add(BatchJobInstanceAdapter, BatchTransactionContext, Record) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

add(BatchJobInstanceAdapter, BatchTransactionContext, Record) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

buffers the given Record for the given BatchJobInstanceAdapter

addBatchProcessingListener(BatchProcessingListener) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListenersOwner

Registers the given BatchProcessingListener for notifications triggered by any DefaultBatchJobInstances regardless of the owning BatchJob.

addBatchProcessingListener(BatchJob, BatchProcessingListener) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListenersOwner

Registers the given BatchProcessingListener for notifications triggered by DefaultBatchJobInstances of a given BatchJob.

addBatchProcessingListener(BatchProcessingListener) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

Registers the given BatchProcessingListener for notifications triggered by any DefaultBatchJobInstances regardless of the owning BatchJob.

addBatchProcessingListener(BatchJob, BatchProcessingListener) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

Registers the given BatchProcessingListener for notifications triggered by DefaultBatchJobInstances of a given BatchJob.

addToBufferInSplitTransaction(BatchJobInstanceAdapter, RecordBuffer, BatchTransactionContext, BatchTransactionContextProvider, Record) - Static method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.BufferUtils

Adds a record to the given buffer using a transaction other than the current one.

addVariable(String, TypedValue<?>) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Sets a record var

AGGREGATOR_RECORD - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

AGGREGATOR_RECORDS - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

AggregatorRecordBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

An implementation of RecordBuffer to be used by DefaultBatchStepAggregator instances.

AggregatorRecordBuffer(String, int, BatchEngine, BatchStepAdapter, Processor, ComponentLocation, NotificationDispatcher, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

ALL_INTERNAL_VARS - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

applyToEither(CompletionStage<? extends Void>, Function<? super Void, U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

applyToEitherAsync(CompletionStage<? extends Void>, Function<? super Void, U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

applyToEitherAsync(CompletionStage<? extends Void>, Function<? super Void, U>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

asEventBuilder(BatchJobAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.BatchEvent

Deprecated.

use BatchEvent.asEventBuilder(BatchJobAdapter, CompletableFuture)

asEventBuilder(BatchJobAdapter, CompletableFuture<Void>) - Method in class com.mulesoft.mule.runtime.module.batch.BatchEvent

awaitStop(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchWorkManager

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

awaitStop(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

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

B

BaseBatchProcessingListener - Class in com.mulesoft.mule.runtime.module.batch.internal

Default implementation of BatchProcessingListener which implements all the methods with no-op implementations.

BaseBatchProcessingListener() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListener

BaseBatchProcessingListenerOwner - Class in com.mulesoft.mule.runtime.module.batch.internal

Base class implementation for BatchProcessingListenersOwner which already implements some basic functionality like keeping the list of listeners, add/remove methods, etc.

BaseBatchProcessingListenerOwner() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

BaseBatchTransactionContextWrapper - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

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().

BaseBatchTransactionContextWrapper(BatchTransactionContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

BATCH_DISPATCHER_THREAD_NAME - Static variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchRecordDispatcher

BATCH_ENGINE - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

BATCH_INSTANCE_STORE - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

BATCH_JOB_INSTANCE_ID_ATTRIBUTE_NAME - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

BATCH_JOB_INSTANCE_ID_VARIABLE - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

BATCH_MANAGER - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

BATCH_QUEUE_MANAGER - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

BatchBuildingDefinitionProvider - Class in com.mulesoft.mule.runtime.module.batch.internal.config

Provider of ComponentBuildingDefinition for Batch module components.

BatchBuildingDefinitionProvider() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.config.BatchBuildingDefinitionProvider

BatchContextTransactionManager - Interface in com.mulesoft.mule.runtime.module.batch.engine.buffer

Interface to encapsulate logic involving commit and rollback of batch transactions.

BatchContextTransactionRecorder - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Recorder for batch transaction contexts to prevent commit when an aggregator is flushed.

BatchContextTransactionRecorder(BatchEngine) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.BatchContextTransactionRecorder

BatchEngine - Interface in com.mulesoft.mule.runtime.module.batch.engine

Contains the main logic to execute and orchestrate a BatchJobInstance

batchEngine - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

BatchEvent - Class in com.mulesoft.mule.runtime.module.batch

Internal representation of the CoreEvent which triggered a BatchJobInstance.

BatchEvent(String, Map<String, TypedValue<?>>, ComponentLocation) - Constructor for class com.mulesoft.mule.runtime.module.batch.BatchEvent

BatchEvent(String, Map<String, TypedValue<?>>, ComponentLocation, Optional<Map<String, String>>) - Constructor for class com.mulesoft.mule.runtime.module.batch.BatchEvent

BatchException - Exception in com.mulesoft.mule.runtime.module.batch.exception

BatchException(I18nMessage, BatchJobInstance) - Constructor for exception com.mulesoft.mule.runtime.module.batch.exception.BatchException

BatchException(I18nMessage, Throwable, BatchJobInstance) - Constructor for exception com.mulesoft.mule.runtime.module.batch.exception.BatchException

BatchException(Throwable, BatchJobInstance) - Constructor for exception com.mulesoft.mule.runtime.module.batch.exception.BatchException

BatchFailureHandlingException - Exception in com.mulesoft.mule.runtime.module.batch.internal.exception

Represents an exception that occurs during another exception handling.

BatchFailureHandlingException(Throwable, Throwable, BatchJobInstance) - Constructor for exception com.mulesoft.mule.runtime.module.batch.internal.exception.BatchFailureHandlingException

Builds this exception

BatchGlobalBindingContextProvider - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Registers the expression bindings for the batch module

BatchGlobalBindingContextProvider() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.BatchGlobalBindingContextProvider

BatchJob - Interface in com.mulesoft.mule.runtime.module.batch.api

The abstract definition of a batch job.

BatchJobAdapter - Interface in com.mulesoft.mule.runtime.module.batch.engine

Adapter interface to access BatchJob related functionality that we don't want exposed as part of the public API

BatchJobInstanceAdapter - Interface in com.mulesoft.mule.runtime.module.batch.engine

Adapter interface to access BatchJobInstance related functionality that we don't want exposed as part of the API

BatchJobInstanceSchedulingStrategy - Interface in com.mulesoft.mule.runtime.module.batch.scheduling

Each implementation of this interface represents an algorithm to decide which is the running job instance that should be the next to be executed.

BatchJobInstanceStore - Interface in com.mulesoft.mule.runtime.module.batch.engine

This interface defines the behavior expected from the component that the BatchEngine will use to to handle its persistent data

BatchJobInstanceTerminatorWork - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.threading

Terminates a job instance with no records left to proccess without blocking the dispatcher thread.

BatchJobInstanceTerminatorWork(BatchEngine, BatchJobInstanceAdapter) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchJobInstanceTerminatorWork

BatchJobResultAdapter - Interface in com.mulesoft.mule.runtime.module.batch.internal

Adapter interface that allows access to functionality that is not to be exposed in the facing API

BatchLockFactory - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

Consumer of LockProvider for the batch module.

BatchLockFactory() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchLockFactory

BatchManager - Interface in com.mulesoft.mule.runtime.module.batch.api

public API for external components to access functionality and state of the Batch Module

BatchMelExtension - Class in com.mulesoft.mule.runtime.module.batch.internal.el.mel

Deprecated.

BatchMelExtension() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelExtension

Deprecated.

BatchMelFunctions - Class in com.mulesoft.mule.runtime.module.batch.internal.el.mel

Deprecated.

BatchMelFunctions() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

BatchMessageBlock - Class in com.mulesoft.mule.runtime.module.batch.internal

This construct represents a block of a BatchJob in which processing does't happen at a Record level but at a traditional message level

BatchMessageBlock() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.BatchMessageBlock

BatchNotification - Class in com.mulesoft.mule.runtime.module.batch.api.notification

BatchNotification(BatchJobInstance, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

BatchNotification(BatchJobInstance, Exception, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

BatchNotification(BatchJobInstance, BatchStep, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

BatchNotification(BatchJobInstance, BatchStep, Record, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

BatchNotification(BatchJobInstance, BatchStep, Exception, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

BatchNotification(BatchJobInstance, BatchStep, Record, Exception, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

BatchNotificationListener - Interface in com.mulesoft.mule.runtime.module.batch.api.notification

Notification listener for BatchNotification notifications

BatchProcessingListener - Interface in com.mulesoft.mule.runtime.module.batch

Listener interface for internal batch components.

BatchProcessingListenersOwner - Interface in com.mulesoft.mule.runtime.module.batch

Components who want to broadcast internal notifications should implement this interface in order to publish a setter for a BatchProcessingListener

BatchProcessingTemplate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

Implementation of the template design pattern to execute a Processor chain in different sections of a BatchJob such as BatchStep, DefaultBatchStepAggregator or the on-complete section implemented through BatchMessageBlock

BatchProcessingTemplate(ReactiveProcessor, ComponentLocation, FlowTraceManager, StreamCloserService) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

Creates a new instance

BatchProperties - Interface in com.mulesoft.mule.runtime.module.batch

BatchQueueDelegate - Interface in com.mulesoft.mule.runtime.module.batch.engine.queue

Implementation of the delegate design pattern to separate batch related behavior over a Queue from the queue itself.

BatchQueueLoader - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

This components loads the contents of a CoreEvent into a batch stepping queue.

BatchQueueLoader(BatchEngine, int, SplittingStrategy<CoreEvent, MessageSequence<?>>, NotificationDispatcher) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.BatchQueueLoader

BatchQueueManager - Interface in com.mulesoft.mule.runtime.module.batch.engine.queue

This component is responsible for managing all the queue's related functionality of the batch engine without exposing any details about the underlying queueing mechanism.

batchQueueManager - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

BatchRecordDispatcher - Interface in com.mulesoft.mule.runtime.module.batch.engine

Runs in the background and monitors the Queues of every BatchJobInstanceAdapter in executable state.

BatchRecordDispatcherDelegate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

Delegate implementation of BatchRecordDispatcher which processes in a single thread backed by a Scheduler and dispatches processes using a BatchWorkManager

BatchRecordDispatcherDelegate(BatchEngine, BatchWorkManager) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchRecordDispatcherDelegate

BatchRecordProcessors - Class in com.mulesoft.mule.runtime.module.batch.internal

This class simple holds a List of BatchStepAdapter to make configuration parsing easier

BatchRecordProcessors() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.BatchRecordProcessors

BatchRecordWork - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.threading

BatchRecordWork(BatchEngine, BatchJobAdapter, BatchTransactionContext, BatchProcessingListener, List<Record>) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchRecordWork

BatchResultReporter<T> - Interface in com.mulesoft.mule.runtime.module.batch.internal.reporting

This component generates reports about the execution of a given BatchJob.

BatchRuntimeExtensionModelProvider - Class in com.mulesoft.mule.runtime.module.batch.api.extension

A RuntimeExtensionModelProvider for Mule's EE Batch components.

BatchRuntimeExtensionModelProvider() - Constructor for class com.mulesoft.mule.runtime.module.batch.api.extension.BatchRuntimeExtensionModelProvider

BatchStep - Interface in com.mulesoft.mule.runtime.module.batch.api

A processing unit within a BatchJob

BatchStepAdapter - Interface in com.mulesoft.mule.runtime.module.batch.engine

Adapter interface to access BatchStep related functionality that we don't want exposed as part of the API

BatchStepAggregator - Interface in com.mulesoft.mule.runtime.module.batch

Aggregates all the steps in a batch process

BatchStepExceptionSummaryAdapter - Interface in com.mulesoft.mule.runtime.module.batch.internal

Adapter interface for BatchStepExceptionSummary implementations, providing access to functionality that we don't want exposed on the public API.

BatchTransactionContext - Interface in com.mulesoft.mule.runtime.module.batch.engine.transaction

Represents the transaction that batch uses to read/write into its persistent queues.

BatchTransactionContextFactory - Interface in com.mulesoft.mule.runtime.module.batch.engine.transaction

Factory class for instances of BatchTransactionContext It keeps track of the created contexts so that upon mule shutdown, any transactions still active (meaning, transactions that still hasn't been rolled back or committed) are rolled back automatically to prevent data loss.

BatchTransactionContextProvider - Interface in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

Provides a BatchTransactionContext for a given BatchJobInstanceAdapter.

BatchUtils - Class in com.mulesoft.mule.runtime.module.batch.util

BatchUtils() - Constructor for class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

BatchWorkManager - Interface in com.mulesoft.mule.runtime.module.batch.internal.engine.threading

Manages and schedules all the concurrent BatchRecordWork needed to process one or many BatchJobInstanceAdapter in parallel.

before(BatchJobInstanceAdapter, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

This method is invoked right before each execution of BatchProcessingTemplate.messageProcessor.

beginMonitoring() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.history.DefaultHistoryExpirationMonitor

beginMonitoring() - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.history.HistoryExpirationMonitor

Begins monitoring and disposal of historic job instances

beginTransaction() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Starts the transaction

beginTransaction() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

beginTransaction() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Starts the transaction

brokersSize() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

brokersSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

BufferUtils - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Utilities for handling buffers

BufferUtils() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.BufferUtils

buildExceptionLogMessage(Throwable) - Static method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Attempts top get meaningful information from an exception and build a message from it.

buildExceptionLogMessage(BatchJobInstance, BatchStep, Exception) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

buildQueueName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

Implementors uses this method to construct the name of the underlying queue

buildQueueName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.SteppingQueueDelegate

Implementors uses this method to construct the name of the underlying queue

buildQueueName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.StreamingAggregatorInputQueueDelegate

Implementors uses this method to construct the name of the underlying queue

buildQueueName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.StreamingAggregatorOutputQueueDelegate

Implementors uses this method to construct the name of the underlying queue

buildReport(BatchJob, BatchJobResult) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.reporting.BatchResultReporter

Generates a report for the given parameters

buildReport(BatchJob, BatchJobResult) - Method in class com.mulesoft.mule.runtime.module.batch.internal.reporting.ExceptionsInTextBatchResultReporter

If the given BatchJobResult accounts for errors, then a table formatted String is returned with the following columns: Exception Type, Step name, and Count (how many times the given exception type was found for that step).

C

call(Object[], BindingContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.ExceptionForStepFunction

call(Object[], BindingContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetFirstExceptionFunction

call(Object[], BindingContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetLastExceptionFunction

call(Object[], BindingContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetStepExceptionsFunction

call(Object[], BindingContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsFailedRecordFunction

call(Object[], BindingContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsSuccessfulRecordFunction

cancel(String, String) - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Same as BatchManager.stop(String, String) but definitive.

cancel(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Stops the jobInstance if it's executing (by delegating into BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean).

cancel(String, String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Same as BatchManager.stop(String, String) but definitive.

cancel(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Stops the jobInstance if it's executing (by delegating into BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean).

cancel(boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

cancelAllRunningInstance() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Invokes BatchEngine.cancel(BatchJobInstanceAdapter) on every running instance of any job

cancelAllRunningInstance() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Invokes BatchEngine.cancel(BatchJobInstanceAdapter) on every running instance of any job

cancelAllRunningInstances() - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Invokes BatchManager.cancel(String, String) for every BatchJobInstance in running state.

cancelAllRunningInstances() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Invokes BatchManager.cancel(String, String) for every BatchJobInstance in running state.

clearFailedRecords(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Removes all the failed records records stored for the given BatchJobAdapter

clearFailedRecords(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

Removes all the failed records records stored for the given BatchJobAdapter

close() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

close() - Method in class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializationAwareQueueProducer

close() - Method in class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializerAwareObjectStoreProducer

closeAndRollback() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContextFactory

closes this factory meaning that it will not accept requests to create any addiitional BatchTransactionContexts.

closeAndRollback() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContextFactory

closes this factory meaning that it will not accept requests to create any addiitional BatchTransactionContexts.

com.mulesoft.mule.runtime.module.batch - package com.mulesoft.mule.runtime.module.batch

com.mulesoft.mule.runtime.module.batch.api - package com.mulesoft.mule.runtime.module.batch.api

com.mulesoft.mule.runtime.module.batch.api.extension - package com.mulesoft.mule.runtime.module.batch.api.extension

com.mulesoft.mule.runtime.module.batch.api.notification - package com.mulesoft.mule.runtime.module.batch.api.notification

com.mulesoft.mule.runtime.module.batch.api.record - package com.mulesoft.mule.runtime.module.batch.api.record

com.mulesoft.mule.runtime.module.batch.engine - package com.mulesoft.mule.runtime.module.batch.engine

com.mulesoft.mule.runtime.module.batch.engine.buffer - package com.mulesoft.mule.runtime.module.batch.engine.buffer

com.mulesoft.mule.runtime.module.batch.engine.history - package com.mulesoft.mule.runtime.module.batch.engine.history

com.mulesoft.mule.runtime.module.batch.engine.queue - package com.mulesoft.mule.runtime.module.batch.engine.queue

com.mulesoft.mule.runtime.module.batch.engine.transaction - package com.mulesoft.mule.runtime.module.batch.engine.transaction

com.mulesoft.mule.runtime.module.batch.exception - package com.mulesoft.mule.runtime.module.batch.exception

com.mulesoft.mule.runtime.module.batch.internal - package com.mulesoft.mule.runtime.module.batch.internal

com.mulesoft.mule.runtime.module.batch.internal.commit - package com.mulesoft.mule.runtime.module.batch.internal.commit

com.mulesoft.mule.runtime.module.batch.internal.config - package com.mulesoft.mule.runtime.module.batch.internal.config

com.mulesoft.mule.runtime.module.batch.internal.el.dw - package com.mulesoft.mule.runtime.module.batch.internal.el.dw

com.mulesoft.mule.runtime.module.batch.internal.el.mel - package com.mulesoft.mule.runtime.module.batch.internal.el.mel

com.mulesoft.mule.runtime.module.batch.internal.engine - package com.mulesoft.mule.runtime.module.batch.internal.engine

com.mulesoft.mule.runtime.module.batch.internal.engine.buffer - package com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

com.mulesoft.mule.runtime.module.batch.internal.engine.history - package com.mulesoft.mule.runtime.module.batch.internal.engine.history

com.mulesoft.mule.runtime.module.batch.internal.engine.queue - package com.mulesoft.mule.runtime.module.batch.internal.engine.queue

com.mulesoft.mule.runtime.module.batch.internal.engine.threading - package com.mulesoft.mule.runtime.module.batch.internal.engine.threading

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

com.mulesoft.mule.runtime.module.batch.internal.exception - package com.mulesoft.mule.runtime.module.batch.internal.exception

com.mulesoft.mule.runtime.module.batch.internal.record - package com.mulesoft.mule.runtime.module.batch.internal.record

com.mulesoft.mule.runtime.module.batch.internal.reporting - package com.mulesoft.mule.runtime.module.batch.internal.reporting

com.mulesoft.mule.runtime.module.batch.internal.scheduling - package com.mulesoft.mule.runtime.module.batch.internal.scheduling

com.mulesoft.mule.runtime.module.batch.internal.streaming - package com.mulesoft.mule.runtime.module.batch.internal.streaming

com.mulesoft.mule.runtime.module.batch.reporting - package com.mulesoft.mule.runtime.module.batch.reporting

com.mulesoft.mule.runtime.module.batch.scheduling - package com.mulesoft.mule.runtime.module.batch.scheduling

com.mulesoft.mule.runtime.module.batch.util - package com.mulesoft.mule.runtime.module.batch.util

commit(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.buffer.BatchContextTransactionManager

commit

commit() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Commits the transaction

commit() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

commit(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

commit() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

commit() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Commits the transaction

commit(BatchTransactionContext) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

complete(Void) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

completeExceptionally(Throwable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

completeWorkOnBlock(List<Record>, boolean, BatchProcessingListener, BatchTransactionContext) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

Perform the completion callback for each record in the block as well as any further completion operation needed related to the transaction context.

configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

Configures the event (set payload, properties, etc) to is going to be used when flushing the aggregated records through the AggregatorRecordBuffer.chain

configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorRecordBuffer

configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorTransactionRecordBuffer

configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

configureContext(ExpressionLanguageContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelExtension

Deprecated.

copy() - Method in class com.mulesoft.mule.runtime.module.batch.internal.commit.ImmutableRecordAwareList

Creates a semi-shallow copy of this instance.

countOpenTransactions() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContextFactory

For monitoring and testing purposes only

countOpenTransactions() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContextFactory

createEventBuilder(Record, BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.

createEventBuilder(Record, BatchJobInstanceAdapter, CompletableFuture<Void>) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.

createEventBuilder(Record, BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.

createEventBuilder(Record, BatchJobInstanceAdapter, CompletableFuture<Void>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.

createExtensionModel() - Method in class com.mulesoft.mule.runtime.module.batch.api.extension.BatchRuntimeExtensionModelProvider

createFailureExceptionFunction() - Static method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

createGetFirstExceptionFunction() - Static method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

createGetLastExceptionFunction() - Static method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

createGetStepExceptionsFunction() - Static method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

createIsFailedRecordFunction() - Static method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

createIsSuccessfulRecordFunction() - Static method in class com.mulesoft.mule.runtime.module.batch.internal.el.mel.BatchMelFunctions

Deprecated.

createLock(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchLockFactory

Provides a lock to create thread safe Mule components.

createNewJobInstance(BatchJobAdapter, CoreEvent) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Creates and initialises a new BatchJobInstanceAdapter related to the given job.

createNewJobInstance(BatchJobAdapter, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Creates and initialises a new BatchJobInstanceAdapter related to the given job.

createTransactionContext(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Creates a new BatchTransactionContext referencing the given {@link BatchJobInstanceAdapter}

createTransactionContext(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContextFactory

Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter

createTransactionContext(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Creates a new BatchTransactionContext referencing the given {@link BatchJobInstanceAdapter}

createTransactionContext(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContextFactory

Creates and tracks a new BatchTransactionContext associated to the given BatchJobInstanceAdapter

CreationTimeSequentialSchedulingStrategy - Class in com.mulesoft.mule.runtime.module.batch.internal.scheduling

Implementation of BatchJobInstanceSchedulingStrategy in which executable instances are sorted by BatchJobInstance.getCreationTime() and the one with the lowest value is returned

CreationTimeSequentialSchedulingStrategy() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.scheduling.CreationTimeSequentialSchedulingStrategy

D

decrementConsumers() - Method in interface com.mulesoft.mule.runtime.module.batch.api.record.RecordCompletionTracker

Reverse of RecordCompletionTracker.incrementConsumers()

decrementConsumers() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

DEFAULT_BLOCK_SIZE - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

DEFAULT_MAX_CONCURRENCY - Static variable in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

DefaultBatchEngine - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

Default implementation of BatchEngine

DefaultBatchEngine() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

DefaultBatchJob - Class in com.mulesoft.mule.runtime.module.batch.internal

DefaultBatchJob(String, int, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

Creates a new instance

DefaultBatchJobInstance - Class in com.mulesoft.mule.runtime.module.batch.internal

DefaultBatchJobInstance(String, String, CoreEvent) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

DefaultBatchJobInstanceStore - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

Implementation of BatchJobInstanceStore that uses ObjectStore for a persistence mechanism

DefaultBatchJobInstanceStore() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

DefaultBatchJobResult - Class in com.mulesoft.mule.runtime.module.batch.internal

Default implementation for BatchJobResultAdapter

DefaultBatchJobResult(String) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

DefaultBatchManager - Class in com.mulesoft.mule.runtime.module.batch.internal

Default implementation of BatchManager

DefaultBatchManager() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

DefaultBatchQueueManager - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Default implementation of BatchQueueManager

DefaultBatchQueueManager() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

DefaultBatchRecordDispatcher - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

Default implementation of BatchRecordDispatcher which does the monitoring in a single thread and processes using a BatchWorkManager

DefaultBatchRecordDispatcher(BatchEngine, BatchWorkManager, SchedulerService, SchedulerConfig, NotificationListenerRegistry) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchRecordDispatcher

DefaultBatchStep - Class in com.mulesoft.mule.runtime.module.batch.internal

Default implementation of BatchStep

DefaultBatchStep() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

DefaultBatchStepAggregator - Class in com.mulesoft.mule.runtime.module.batch.internal

A semi-transactional boundary in which records are aggregated and processed as a block instead of a Record by Record basis.

DefaultBatchStepAggregator() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

DefaultBatchStepExceptionSummary - Class in com.mulesoft.mule.runtime.module.batch.internal

Default implementation for BatchStepExceptionSummary

DefaultBatchStepExceptionSummary() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepExceptionSummary

DefaultBatchStepResult - Class in com.mulesoft.mule.runtime.module.batch.internal

Default implementation of BatchStepResult

DefaultBatchStepResult() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

DefaultBatchTransactionContext - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

Default implementation of BatchTransactionContext

DefaultBatchTransactionContext(BatchJobAdapter, BatchJobInstanceAdapter, QueueSession) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

DefaultBatchTransactionContextFactory - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

Default implementation of BatchTransactionContextFactory

DefaultBatchTransactionContextFactory(BatchEngine) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContextFactory

DefaultBatchWorkManager - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.threading

Default implementation of BatchWorkManager

DefaultBatchWorkManager() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

DefaultHistoryExpirationMonitor - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.history

Default implementation of HistoryExpirationMonitor

This implementation is based on one single thread which runs on a given frequency.

DefaultHistoryExpirationMonitor(BatchEngine, BatchJobInstanceStore, long, TimeUnit, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.history.DefaultHistoryExpirationMonitor

delegate() - Method in class com.mulesoft.mule.runtime.module.batch.internal.commit.ImmutableRecordAwareList

delegate - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

delete(String, String) - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Deletes the given BatchJobInstance from persistent store

delete(String, String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Deletes the given BatchJobInstance from persistent store

dispatch(BatchTransactionContext, Collection<Record>) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Writes the given records into the queue

dispatch(BatchTransactionContext, Collection<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

Writes the given records into the queue

dispatch(BatchTransactionContext, Collection<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.SteppingQueueDelegate

Writes the given records into the queue

dispatchAndCommit(BatchTransactionContext, BatchJobInstanceAdapter, List<Record>, BatchContextTransactionManager) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Writes the given records into the queue and commits the transaction

dispatchAndCommit(BatchTransactionContext, BatchJobInstanceAdapter, List<Record>, BatchContextTransactionManager) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

dispatchAndCommit(BatchTransactionContext, BatchJobInstanceAdapter, List<Record>, BatchContextTransactionManager) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.SteppingQueueDelegate

dispose(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Disposes the underlying Queues for the given BatchJobInstanceAdapter

dispose() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

dispose() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

dispose(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

Disposes the underlying Queues for the given BatchJobInstanceAdapter

dispose() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

disposeBroker(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

Disposes just the broker for the queues.

disposeBroker(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

Disposes just the broker for the queues.

disposeQueues(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

Disposes all initialized queues associated to the given BatchJobInstanceAdapter

disposeQueues(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

Disposes all initialized queues associated to the given BatchJobInstanceAdapter

doFlush(BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

Executes the template returned by AggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap, Processor, MuleContext) using the CoreEvent returned by AggregatorRecordBuffer.configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap)

doFlush(BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

Implement this logic to perform specific flushing logic

doFlush(BatchJobInstanceAdapter, Multimap<BatchTransactionContext, Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.LoadingQueueBuffer

doFlush(BatchJobInstanceAdapter, BatchTransactionContext, List<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorInputQueueBuffer

doFlush(BatchJobInstanceAdapter, BatchTransactionContext, List<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

doForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorInputQueueBuffer

doForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

doGetObject() - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationCriteriaFactoryBean

doGetObject() - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationPolicyFactoryBean

E

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

equals(Object) - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStep

eventBuilderConfigurerIterator() - Method in class com.mulesoft.mule.runtime.module.batch.internal.commit.ImmutableRecordAwareList

exceptionally(Function<Throwable, ? extends Void>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

ExceptionForStepFunction - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Returns the Exception that the current record experienced in a given step, or null if the record didn't fail on that step.

ExceptionForStepFunction() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.ExceptionForStepFunction

ExceptionHistory - Class in com.mulesoft.mule.runtime.module.batch.exception

Keeps track of exception types found and the stack traces that generated them

ExceptionHistory() - Constructor for class com.mulesoft.mule.runtime.module.batch.exception.ExceptionHistory

exceptionReporter - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

ExceptionSerializationWrapper - Exception in com.mulesoft.mule.runtime.module.batch.internal.exception

ExceptionSerializationWrapper(Exception) - Constructor for exception com.mulesoft.mule.runtime.module.batch.internal.exception.ExceptionSerializationWrapper

ExceptionsInTextBatchResultReporter - Class in com.mulesoft.mule.runtime.module.batch.internal.reporting

Implementation of BatchResultReporter that generates a text table if the result accounts for failures.

ExceptionsInTextBatchResultReporter() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.reporting.ExceptionsInTextBatchResultReporter

executable(BatchJobInstance) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchWorkManager

Tracks the given jobInstance as an executable one.

executable(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

Tracks the given jobInstance as an executable one.

execute(CoreEvent) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

Executes the batch and generates a BatchJobInstance in loading state

execute(CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

F

finishExecution(BatchJobInstanceAdapter, boolean) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Ends the execution of the given jobInstance

finishExecution(BatchJobInstanceAdapter, boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Finishes execution of the BatchJobInstanceAdapter in a successful way and makes it no longer eligible for execution by the steps.

finishIfCompleted(BatchJobInstanceAdapter, BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

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)

finishIfCompleted(BatchJobInstanceAdapter, BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

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)

FixedAggregatorRecordBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of AggregatorRecordBuffer for non streaming DefaultBatchStepAggregator.

FixedAggregatorRecordBuffer(int, boolean, BatchEngine, BatchStepAdapter, Processor, ComponentLocation, NotificationDispatcher, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorRecordBuffer

FixedAggregatorTransactionRecordBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of AggregatorRecordBuffer for non streaming DefaultBatchStepAggregator.

FixedAggregatorTransactionRecordBuffer(int, boolean, BatchEngine, BatchStepAdapter, Processor, ComponentLocation, NotificationDispatcher, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorTransactionRecordBuffer

flush(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

Flushes the buffered Records for the given BatchJobInstanceAdapter.

flush(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

flush(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

Flushes the buffered Records for the given BatchJobInstanceAdapter.

flush(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

Flushes the buffered Records for the given BatchJobInstanceAdapter.

flush(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

flush(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

Flushes the buffered Records for the given BatchJobInstanceAdapter.

flushAndForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.BatchContextTransactionRecorder

Flushes all the records corresponding to the batch context for the job instance.

flushAndForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorTransactionRecordBuffer

flushAndForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

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).

flushAndForget(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

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).

flushAndForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

flushAndForget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

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).

forCollection(Collection<BatchJob>) - Static method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

forget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorRecordBuffer

For this implementation, to forget means to flush whatever records are currently buffered.

forget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorTransactionRecordBuffer

For this implementation, to forget means to flush whatever records are currently buffered.

forget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

Releases all tracking information for the given BatchJobInstanceAdapter

forget(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

Releases all tracking information for the given BatchJobInstanceAdapter

forget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

forget(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

Releases all tracking information for the given BatchJobInstanceAdapter

G

generateJobInstanceId(CoreEvent) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

Generates an id for a BatchJobInstance to be created per the given event

generateJobInstanceId(CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

Generates an id by evaluating the DefaultBatchJob.jobInstanceIdExpression on the given event.

get() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

get(long, TimeUnit) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

get(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BatchTransactionContextProvider

Returns a BatchTransactionContext for the given BatchJobInstanceAdapter

get(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.ManagedBatchTransactionContextProvider

Returns a BatchTransactionContext for the given BatchJobInstanceAdapter

getAllVariables() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

getAttributes() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

getAttributes() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

getBatchEngine() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

getBatchEngine() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getBatchEngine() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

getBatchEvent() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter

Returns the BatchEvent that was used to start this instance

getBatchEvent() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

Returns the BatchEvent that was used to start this instance

getBatchJobInstanceId() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getBatchJobInstanceId() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getBatchJobInstanceSchedulingStrategy() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

getBatchJobInstanceSchedulingStrategy() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getBatchJobs() - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Returns all the BatchJob declared in the current mule context

getBatchJobs() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Returns all defined BatchJobs

getBatchJobs() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Returns all the BatchJob declared in the current mule context

getBatchJobs() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Returns all defined BatchJobs

getBatchQueueManager() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Returns the BatchQueueManager in which queueing operations are delegated

getBatchQueueManager() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Returns the BatchQueueManager in which queueing operations are delegated

getBatchStepAggregator() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

If this step has an aggregator block, then this method returns the underlying BatchStepAggregator

getBatchStepAggregator() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

getBatchStepResults() - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Returns a Map in which the key is the name of a step and the value is a BatchStepResult

getBatchStepResults() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Returns a Map in which the key is the name of a step and the value is a BatchStepResult

getBatchTransactionContextFactory() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

For monitoring and testing purposes only

getBatchTransactionContextFactory() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

For monitoring and testing purposes only

getBindingContext() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.BatchGlobalBindingContextProvider

getBlockFrom(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Returns the records in the stepping queue which corresponds to the BatchJobInstance referenced by the given context

getBlockFrom(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

getBlockSize(BatchJobInstance) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Returns the BatchJobAdapter.getBlockSize() for the BatchJob that owns the given jobInstance

getBlockSize() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

For performance reasons, batch records are queued and scheduled in blocks.

getBlockSize() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

getBlockSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

For performance reasons, batch records are queued and scheduled in blocks.

getBlockSize(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Returns the BatchJobAdapter.getBlockSize() for the BatchJob that owns the given jobInstance

getBlockSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

getBlockSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

getCause() - Method in exception com.mulesoft.mule.runtime.module.batch.internal.exception.ExceptionSerializationWrapper

getCompletionCallback() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

getComponentBuildingDefinitions() - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.BatchBuildingDefinitionProvider

getCorrelationId() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

getCorrelationId() - Method in class com.mulesoft.mule.runtime.module.batch.BatchEvent

getCreationTime() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

getCreationTime() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

getCurrentStepId() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

The id of the BatchStep which is currently processing this record or is to process it next

getDelegate(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.SteppingQueueBuffer

Returns a BatchQueueDelegate for stepping queues returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)

getDelegate(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorInputQueueBuffer

Returns a BatchQueueDelegate for streaming aggregator queues

getDelegate(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorOutputQueueBuffer

getDelegate(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

Returns the BatchQueueDelegate through which information will be written into the queue

getDelegate() - Method in exception com.mulesoft.mule.runtime.module.batch.internal.exception.ExceptionSerializationWrapper

getDerivate() - Method in exception com.mulesoft.mule.runtime.module.batch.internal.exception.BatchFailureHandlingException

getElapsedTimeInMillis() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getElapsedTimeInMillis() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getEventName() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

getException() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

getExceptionForStep(String) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns the Exception found by the step of the given name when processing this record

getExceptionHistory(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

Returns the ExceptionHistory associated to the given BatchJobInstanceAdapter

getExceptionHistory(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

getExceptionHistory(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.reporting.StepExceptionReporter

getExceptionsCount() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepExceptionSummary

getExceptionsCount() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStepExceptionSummary

getExceptionSummary() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

getExceptionSummary() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStepResult

getExecutingInstances() - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Returns the instance of BatchJobInstance that are in an executing state

getExecutingInstances() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Retrieves all the BatchJobInstance that are currently elegible for execution.

getExecutingInstances() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Returns the instance of BatchJobInstance that are in an executing state

getExecutingInstances() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

Retrieves all the BatchJobInstance that are currently elegible for execution.

getFailedRecords(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Retrieves all the records of the given BatchJobInstanceAdapter that failed in at least one step and which execution has finished

getFailedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getFailedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

getFailedRecords(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

getFailedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getFailedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStepResult

getFailedStepsCount() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns how many steps have raised exceptions for this record

getFirstException() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns the first Exception found for this record

GetFirstExceptionFunction - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Returns the first Exception that the current record experienced or null if the record hasn't failed so far

GetFirstExceptionFunction() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetFirstExceptionFunction

getFlushedRecordCount(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorInputQueueBuffer

getHistoryExpirationPolicy() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

getHistoryExpirationPolicy() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getHolderLock() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

getId() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Returns an unmodifiable id associated to this particular instance

getId() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

getId() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

getId() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Returns an unmodifiable id associated to this particular instance

getId() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

getInputPhaseException() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getInputPhaseException() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getJob(String) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

getJob() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Returns the BatchJobAdapter for which this context was built

getJob(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

getJob() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

getJob() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Returns the BatchJobAdapter for which this context was built

getJobFor(BatchJobInstance) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Returns the owning BatchJobAdapter for the given BatchJobInstance

getJobFor(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Returns the owning BatchJobAdapter for the given BatchJobInstance

getJobInstance(String, String) - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Finds a BatchJobInstance and returns it

getJobInstance() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

getJobInstance(String, String) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Returns the BatchJobInstanceAdapter for the given job and id

getJobInstance() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Returns the BatchJobInstanceAdapter for which this context was built

getJobInstance() - Method in exception com.mulesoft.mule.runtime.module.batch.exception.BatchException

getJobInstance(String, String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Finds a BatchJobInstance and returns it

getJobInstance(String, String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

Returns the BatchJobInstanceAdapter for the given job and id

getJobInstance() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

getJobInstance() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Returns the BatchJobInstanceAdapter for which this context was built

getJobInstances(String) - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Returns all the BatchJobInstance available for the given jobName

getJobInstances(String) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Returns all the BatchJobInstance for the given job name

getJobInstances(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Returns all the BatchJobInstance available for the given jobName

getJobInstances(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

Returns all the BatchJobInstance for the given job name

getJobInstanceStore() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Returns the BatchJobInstanceStore in which persistence operations are delegated on

getJobInstanceStore() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Returns the BatchJobInstanceStore in which persistence operations are delegated on

getLastException() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns the last found Exception for this record.

GetLastExceptionFunction - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Returns the last Exception that the current record experienced or null if the record hasn't failed so far

GetLastExceptionFunction() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetLastExceptionFunction

getListener() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchRecordDispatcher

A BatchProcessingListener that you can use to notify this component on a processing event

getListener() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchRecordDispatcherDelegate

getListener() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchRecordDispatcher

getListeners(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

getLoadedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getLoadedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getLoadingPhaseException() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getLoadingPhaseException() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getLocalizedMessage() - Method in exception com.mulesoft.mule.runtime.module.batch.internal.exception.ExceptionSerializationWrapper

getLocation() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

getLocation() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

getLock(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Obtains a Lock for the given jobInstance.

getLock(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Obtains a Lock for the given jobInstance.

getMaxConcurrency() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

getMaxConcurrency() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getMaxFailedRecords() - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchJob

The number of max records allowed to fail before failing the job

getMaxFailedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

The number of max records allowed to fail before failing the job

getMaxFailedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

getMessage() - Method in exception com.mulesoft.mule.runtime.module.batch.internal.exception.ExceptionSerializationWrapper

getMessageProcessors() - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchMessageBlock

getMuleContext() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

getMuleContext() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getName() - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchStep

The name of the step.

getName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

getName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

getName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

getName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStep

getNextStep() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

Returns the BatchStep that follows right after this one

getNextStep() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

getNow(Void) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

getNumberOfDependents() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

getOnCompleteBlock() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

The job's on complete block if configured

getOnCompleteBlock() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

The job's on complete block if configured

getOnCompletePhaseException() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getOnCompletePhaseException() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getOwnedMessageProcessors() - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchMessageBlock

getOwnedMessageProcessors() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

getOwnedMessageProcessors() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

getOwnerJobName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

getOwnerJobName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

getPayload() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

getPayload() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

getPrevious() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

getProcessedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getProcessedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getProcessingType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getQueue(String) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Returns a Queue attached to the current transaction

getQueue(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

getQueue(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

getQueueName() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter

Returns the name of the queue that this instance uses to pipeline its records

getQueueName() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Returns the underlying Queue's name

getQueueName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

Returns the name of the queue that this instance uses to pipeline its records

getQueueName() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

Returns the underlying Queue's name

getReceivedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

getReceivedRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStepResult

getRecord() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

getRecord(CoreEvent) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

getRecord(BindingContext) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

getRecordCount() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

getRecordCount() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

getResolutionCallback() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

A CompletableFuture which is completed when the transaction is resolved.

getResolutionCallback() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

getResolutionCallback() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

A CompletableFuture which is completed when the transaction is resolved.

getResult() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

getResult() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

getResultForStep(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getResultForStep(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getSize() - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

getSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

getSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

getSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializationAwareQueueProducer

getSize() - Method in class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializerAwareObjectStoreProducer

getStatus() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

getStatus() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

getStep() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

getStepById(String) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

Returns the step of the given id

getStepById(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

Returns the step of the given id

getStepExceptions() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns an unmodifiable Map in which the key is the new of a BatchStep and the value is an exception found in that step for the this record.

GetStepExceptionsFunction - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Returns a Map which keys are the names of the steps in which the current Record has failed.

GetStepExceptionsFunction() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetStepExceptionsFunction

getSteppingQueueSize(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Deprecated.

on 4.3.0, use BatchEngine.getBlockFrom(BatchTransactionContext)

getSteppingQueueSize(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

getSteps() - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchJob

getSteps() - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchRecordProcessors

getSteps() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

getSteps() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

getSuccessfulRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getSuccessfulRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

getSuccessfulRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getSuccessfulRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStepResult

getTotalRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

getTotalRecords() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

getTrackedContextsCount() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContextFactory

For monitoring purposes

getVariable(String) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns the value for the record variable of the given key

getVars() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

H

handle(BiFunction<? super Void, Throwable, ? extends U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

handleAsync(BiFunction<? super Void, Throwable, ? extends U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

handleAsync(BiFunction<? super Void, Throwable, ? extends U>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

handleException(BatchJobInstanceAdapter, Exception, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

handleSuccess(BatchJobInstanceAdapter, CoreEvent, CoreEvent.Builder) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

hasErrors() - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns whether or not this record found errors in any step

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

hashCode() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStep

hasNext() - Method in class com.mulesoft.mule.runtime.module.batch.internal.commit.RecordAwareEventIterator

hasNext() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

HistoryExpirationCriteria - Class in com.mulesoft.mule.runtime.module.batch.engine.history

An age based criteria about if a BatchJobInstance should be expired or not.

HistoryExpirationCriteria(long, TimeUnit) - Constructor for class com.mulesoft.mule.runtime.module.batch.engine.history.HistoryExpirationCriteria

Creates a new instance

HistoryExpirationCriteriaFactoryBean - Class in com.mulesoft.mule.runtime.module.batch.internal.config

FactoryBean for instances of HistoryExpirationCriteria

HistoryExpirationCriteriaFactoryBean() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationCriteriaFactoryBean

HistoryExpirationMonitor - Interface in com.mulesoft.mule.runtime.module.batch.internal.engine.history

Monitors historic batch job instances which can be removed from the records.

HistoryExpirationPolicy - Class in com.mulesoft.mule.runtime.module.batch.engine.history

Determines if a BatchJobInstance should be expired from the historic records.

HistoryExpirationPolicy(HistoryExpirationCriteria) - Constructor for class com.mulesoft.mule.runtime.module.batch.engine.history.HistoryExpirationPolicy

Creates a new instance

HistoryExpirationPolicyFactoryBean - Class in com.mulesoft.mule.runtime.module.batch.internal.config

FactoryBean for instances of HistoryExpirationCriteria

HistoryExpirationPolicyFactoryBean() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationPolicyFactoryBean

I

ImmutableBatchJob - Class in com.mulesoft.mule.runtime.module.batch.internal

Immutable view of a BatchJob

ImmutableBatchJob(BatchJob) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJob

ImmutableBatchJobInstance - Class in com.mulesoft.mule.runtime.module.batch.internal

Immutable view of a BatchJobInstance

ImmutableBatchJobInstance(BatchJobInstance) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobInstance

ImmutableBatchJobResult - Class in com.mulesoft.mule.runtime.module.batch.internal

Immutable view of ImmutableBatchJobResult

ImmutableBatchJobResult(BatchJobResult) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

ImmutableBatchStep - Class in com.mulesoft.mule.runtime.module.batch.internal

Immutable view of a BatchStep

ImmutableBatchStep(BatchStep) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStep

ImmutableBatchStepExceptionSummary - Class in com.mulesoft.mule.runtime.module.batch.internal

Immutable view of BatchStepExceptionSummary

ImmutableBatchStepExceptionSummary(BatchStepExceptionSummary) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchStepExceptionSummary

ImmutableBatchStepResult - Class in com.mulesoft.mule.runtime.module.batch.internal

Immutable view of BatchStepResult

ImmutableRecordAwareList<T> - Class in com.mulesoft.mule.runtime.module.batch.internal.commit

Decorates a List in such a way that the ImmutableRecordAwareList.iterator() method returns a RecordAwareEventIterator, and that this decorator becomes immutable.

ImmutableRecordAwareList(List<T>, List<Record>) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.commit.ImmutableRecordAwareList

Creates a new instance

incrementConsumers() - Method in interface com.mulesoft.mule.runtime.module.batch.api.record.RecordCompletionTracker

Adds one to the count of components which are currently consuming a Record.

incrementConsumers() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

incrementFailedRecords(Exception, long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

incrementLoadedRecords(long) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Increments the load records count by howMany

incrementLoadedRecords(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Increments the load records count by howMany

incrementReceivedRecords(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

incrementSuccessfulRecords(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepResult

init() - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.BatchBuildingDefinitionProvider

initExpirationPolicy() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchMessageBlock

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchLockFactory

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

initialise() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

InMemoryRecordBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of RecordBuffer which stores the records in memory until such time in which they're to be flushed.

InMemoryRecordBuffer(String, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

isBlockCompleted() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Returns true if the total amount of acknowledged records through the BatchTransactionContext.ackProcessedRecords(int) matches the block size.

isBlockCompleted() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

isBlockCompleted() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Returns true if the total amount of acknowledged records through the BatchTransactionContext.ackProcessedRecords(int) matches the block size.

isBlocking() - Method in interface com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotificationListener

isCancelled() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

isCompletedExceptionally() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

isDone() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

isFailedFor(BatchStep) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Returns whether this record found an exception for the given BatchStep

isFailedOnCompletePhase() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

isFailedOnCompletePhase() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

isFailedOnInputPhase() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

isFailedOnInputPhase() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

isFailedOnLoadingPhase() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

isFailedOnLoadingPhase() - Method in class com.mulesoft.mule.runtime.module.batch.internal.ImmutableBatchJobResult

IsFailedRecordFunction - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Returns whether the current Record has failed on any step.

IsFailedRecordFunction() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsFailedRecordFunction

isLast() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

Whether this step is the last in its BatchJob or not

isLast() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

isStreaming() - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

isStreaming() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

IsSuccessfulRecordFunction - Class in com.mulesoft.mule.runtime.module.batch.internal.el.dw

Returns whether the current Record has not failed on any step.

IsSuccessfulRecordFunction() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsSuccessfulRecordFunction

iterator(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Returns a streaming Iterator to access the contents of the queue.

iterator() - Method in class com.mulesoft.mule.runtime.module.batch.internal.commit.ImmutableRecordAwareList

iterator(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

J

JOB_CANCELLED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

JOB_PROCESS_RECORDS_BEGIN - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

JOB_PROCESS_RECORDS_FAILED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

JOB_STOPPED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

JOB_SUCCESSFUL - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

jobInstance - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

join() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

L

load(BatchJobInstanceAdapter, CoreEvent) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Splits the CoreEvent payload and loads it into the BatchJobInstanceAdapter queue.

load(BatchJobInstanceAdapter, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Splits the CoreEvent payload and loads it into the BatchJobInstanceAdapter queue.

LOAD_PHASE_BEGIN - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

LOAD_PHASE_END - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

LOAD_PHASE_FAILED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

LOAD_PHASE_PROGRESS - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

LoadingQueueBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of InMemoryRecordBuffer used to first load a stepping queue when a BatchJobInstanceAdapter is in BatchJobInstanceStatus.LOADING state

LoadingQueueBuffer(BatchQueueManager, int, NotificationDispatcher) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.LoadingQueueBuffer

M

makeProcessingTemplate(Multimap<BatchTransactionContext, Record>, Processor, MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

Returns the BatchProcessingTemplate through which AggregatorRecordBuffer.chain will be executed

makeProcessingTemplate(Multimap<BatchTransactionContext, Record>, Processor, MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorRecordBuffer

makeProcessingTemplate(Multimap<BatchTransactionContext, Record>, Processor, MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorTransactionRecordBuffer

makeProcessingTemplate(Multimap<BatchTransactionContext, Record>, Processor, MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

ManagedBatchTransactionContextProvider - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.transaction

Default implementation for BatchTransactionContextProvider

ManagedBatchTransactionContextProvider(BatchEngine, boolean) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.ManagedBatchTransactionContextProvider

markAsFailedInStep(BatchStep, Exception) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Registers that this record found an exception on the given BatchStep The given exception will be recoverable through the Record.getStepExceptions() , Record.getExceptionForStep(String) # methods

markAsProcessedByStep(BatchStep) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Registers that the given BatchStep has finished processing this record.

markError(BatchJobInstanceAdapter, List<Record>, Exception) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

Sets the records as failed in this step

match(List<Record>, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.PartialErrorMatcher

muleContext - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

N

newQueueSession() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

newQueueSession() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

next() - Method in class com.mulesoft.mule.runtime.module.batch.internal.commit.RecordAwareEventIterator

next() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

next(List<BatchJobInstance>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.scheduling.CreationTimeSequentialSchedulingStrategy

next(List<BatchJobInstance>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.scheduling.RoundRobinBatchJobSchedulingStrategy

next(List<BatchJobInstance>) - Method in interface com.mulesoft.mule.runtime.module.batch.scheduling.BatchJobInstanceSchedulingStrategy

nextEventBuilderConfigurer() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

nextRecord() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

notificationDispatcher - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

O

obtrudeException(Throwable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

obtrudeValue(Void) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

of(CoreEvent) - Static method in class com.mulesoft.mule.runtime.module.batch.BatchEvent

ON_COMPLETE_BEGIN - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

ON_COMPLETE_END - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

ON_COMPLETE_FAILED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

onException(BatchJobInstanceAdapter, Exception, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

This method is invoked when the execution of BatchProcessingTemplate.messageProcessor throws exception or the result event carries a ExceptionPayload

onExecutableStateTransition(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListener

Notifies that the given BatchJobInstanceAdapter transitioned into an executable state

onExecutableStateTransition(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListener

Notifies that the given BatchJobInstanceAdapter transitioned into an executable state

onFinally(BatchJobInstanceAdapter, CoreEvent, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

This method is invoked when each execution of BatchProcessingTemplate.messageProcessor completes, no matter if was successful or not.

onJobFinished(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListener

Notifies that the given BatchJobInstanceAdapter has been finished

onJobFinished(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListener

Notifies that the given BatchJobInstanceAdapter has been finished

onJobInstanceStateChange(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListener

Notifies that the given BatchJobInstanceAdapter transitioned into a different BatchJobInstanceStatus

onJobInstanceStateChange(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListener

Notifies that the given BatchJobInstanceAdapter transitioned into a different BatchJobInstanceStatus

onJobStopped(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListener

Notifies that the given BatchJobInstanceAdapter has been stopped before completely finishing

onJobStopped(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListener

Notifies that the given BatchJobInstanceAdapter has been stopped before completely finishing

onRecord(Record, BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

Process the given Record for the given BatchJobInstanceAdapter

onRecord(Record, BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

Process the given Record for the given BatchJobInstanceAdapter

onSteppingQueueDispatch(BatchJobInstanceAdapter, Collection<Record>) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListener

Notifies that the given Records were queued into the stepping queue of the given BatchJobInstanceAdapter

onSteppingQueueDispatch(BatchJobInstanceAdapter, Collection<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListener

Notifies that the given Records were queued into the stepping queue of the given BatchJobInstanceAdapter

onSuccess(BatchJobInstanceAdapter, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

This method is invoked when BatchProcessingTemplate.messageProcessor is execute without any exceptions

ORDERED_SEQUENTIAL_STRING - Static variable in class com.mulesoft.mule.runtime.module.batch.internal.scheduling.CreationTimeSequentialSchedulingStrategy

P

parameters() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.ExceptionForStepFunction

parameters() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetFirstExceptionFunction

parameters() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetLastExceptionFunction

parameters() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetStepExceptionsFunction

parameters() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsFailedRecordFunction

parameters() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsSuccessfulRecordFunction

PartialErrorMatcher - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

PartialErrorMatcher(BatchStep) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.PartialErrorMatcher

poll(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Retrieves a block of Record

poll(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

Retrieves a block of Record

process(CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchMessageBlock

process(CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

process(BatchJobInstanceAdapter, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

Executes the BatchProcessingTemplate.messageProcessor provided in the constructor with the given payload.

produce() - Method in class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializationAwareQueueProducer

This implementation will poll from the queue once and will return the obtained item.

produce() - Method in class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializerAwareObjectStoreProducer

PROGRESS_UPDATE - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

R

Record - Class in com.mulesoft.mule.runtime.module.batch.api.record

A record represent the processing unit for a batch job.

Record(TypedValue<Object>) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.record.Record

Record(TypedValue<Object>, TypedValue<Object>) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.record.Record

RECORD_VARIABLE_NAME - Static variable in interface com.mulesoft.mule.runtime.module.batch.BatchProperties

RecordAwareEventIterator<T> - Class in com.mulesoft.mule.runtime.module.batch.internal.commit

Decorates an Iteratorso that each RecordAwareEventIterator.next() invocation sets a Record as a flow var under the BatchProperties.AGGREGATOR_RECORD key in a newly built event..

RecordAwareEventIterator(Iterator<T>, Iterator<Record>) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.commit.RecordAwareEventIterator

Creates a new instance

RecordBuffer - Interface in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Buffer for holding records so that potentially slow operations can be performed in a bulk.

RecordCompletableFuture - Class in com.mulesoft.mule.runtime.module.batch.internal.engine

A RecordCompletionTracker which is also a CompletableFuture.

RecordCompletableFuture() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

RecordCompletableFuture(CompletableFuture<Void>) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

Creates a new instance

RecordCompletionTracker - Interface in com.mulesoft.mule.runtime.module.batch.api.record

Allows to track the concurrent uses of a record.

RecordELAdapter - Class in com.mulesoft.mule.runtime.module.batch.api.record

RecordELAdapter(Record) - Constructor for class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

RecordFilteringStrategy - Class in com.mulesoft.mule.runtime.module.batch.internal.record

RecordFilteringStrategy(AcceptRecordPolicy, String, ExpressionManager) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.record.RecordFilteringStrategy

registerBatchJob(BatchJobAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

registerBatchJob(BatchJobAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

releaseResources(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

Use this method when processing for the given BatchJobInstanceAdapter should stop and thus any allocated resources related to it should be freed.

releaseResources(BatchJobInstanceAdapter, boolean) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Releases the resources still allocated to the given BatchJobInstanceAdapter, including queues and storage

releaseResources(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter

Releases any resources that the step has allocated for the given jobInstance, such as ExceptionHistory, AggregatorRecordBuffer, etc.

releaseResources(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

releaseResources(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

releaseResources(BatchJobInstanceAdapter, boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Releases the resources still allocated to the given BatchJobInstanceAdapter, including queues and storage

remove(BatchJobInstance) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

removes the given BatchJobInstance

remove() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

remove(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

removes the given BatchJobInstance

removeBatchProcessingListener(BatchJob, BatchProcessingListener) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListenersOwner

Removes the given BatchProcessingListener if registered to the given BatchJob

removeBatchProcessingListener(BatchProcessingListener) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchProcessingListenersOwner

Removes the given BatchProcessingListener if registered as global

removeBatchProcessingListener(BatchJob, BatchProcessingListener) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

Removes the given BatchProcessingListener if registered to the given BatchJob

removeBatchProcessingListener(BatchProcessingListener) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

Removes the given BatchProcessingListener if registered as global

removeVariable(String) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

Removes the record variable of the given key

replaceVariables(Map<String, TypedValue<?>>) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

report(BatchJobInstanceAdapter, Exception) - Method in class com.mulesoft.mule.runtime.module.batch.reporting.StepExceptionReporter

reset(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.reporting.StepExceptionReporter

resolveOutputHandlerPayload(CoreEvent, CoreEvent.Builder) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchProcessingTemplate

resume(String, String) - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Resumes execution of a BatchJobInstance which was stopped through the BatchManager.stop(String, String) method.

resume(String, String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Resumes execution of a BatchJobInstance which was stopped through the BatchManager.stop(String, String) method.

resumeExecution(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Resumes execution of a BatchJobInstance which was stopped through the BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean) method.

resumeExecution(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Resumes execution of a BatchJobInstance which was stopped through the BatchEngine.stopExecution(BatchJobInstanceAdapter, boolean) method.

returnType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.ExceptionForStepFunction

returnType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetFirstExceptionFunction

returnType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetLastExceptionFunction

returnType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.GetStepExceptionsFunction

returnType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsFailedRecordFunction

returnType() - Method in class com.mulesoft.mule.runtime.module.batch.internal.el.dw.IsSuccessfulRecordFunction

rollback(BatchTransactionContext, BatchJobInstanceAdapter, List<Record>, MuleException) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.buffer.BatchContextTransactionManager

rollback

rollback() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Rolls the transaction back

rollback() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

rollback(BatchTransactionContext, BatchJobInstanceAdapter, List<Record>, MuleException) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

rollback() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

rollback() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Rolls the transaction back

rollback(BatchTransactionContext) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

ROUND_ROBIN_STRING - Static variable in class com.mulesoft.mule.runtime.module.batch.internal.scheduling.RoundRobinBatchJobSchedulingStrategy

RoundRobinBatchJobSchedulingStrategy - Class in com.mulesoft.mule.runtime.module.batch.internal.scheduling

Implementation of BatchJobInstanceSchedulingStrategy which selects the job instances with a round robin strategy

RoundRobinBatchJobSchedulingStrategy() - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.scheduling.RoundRobinBatchJobSchedulingStrategy

run() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchRecordDispatcherDelegate

run() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.history.DefaultHistoryExpirationMonitor

run() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchJobInstanceTerminatorWork

run() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchRecordWork

runAfterBoth(CompletionStage<?>, Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

runAfterBothAsync(CompletionStage<?>, Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

runAfterBothAsync(CompletionStage<?>, Runnable, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

runAfterEither(CompletionStage<?>, Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

runAfterEitherAsync(CompletionStage<?>, Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

runAfterEitherAsync(CompletionStage<?>, Runnable, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

S

scheduleManagementWork(Runnable) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchWorkManager

Schedules the asynchronous execution of a job management task.

scheduleManagementWork(Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

Schedules the asynchronous execution of a job management task.

scheduleRecordWork(BatchTransactionContext, Runnable) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchWorkManager

Schedules the given work to be executed.

scheduleRecordWork(BatchTransactionContext, Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

Schedules the given work to be executed.

SerializationAwareQueueProducer<T> - Class in com.mulesoft.mule.runtime.module.batch.internal.streaming

Implementation of Producer that reads arrays of byte from a Queue and then uses a ObjectSerializer to deserialized those bytes into an object.

SerializationAwareQueueProducer(Queue, ObjectSerializer) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializationAwareQueueProducer

Creates an instance with 5000 milliseconds as the default polling value

SerializationAwareQueueProducer(Queue, ObjectSerializer, long) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializationAwareQueueProducer

SerializerAwareObjectStoreProducer<T> - Class in com.mulesoft.mule.runtime.module.batch.internal.streaming

Implementation of Producer to stream the contents of a ObjectStore.

SerializerAwareObjectStoreProducer(ObjectStore<byte[]>, ObjectSerializer) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializerAwareObjectStoreProducer

setAcceptExpression(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setAcceptPolicy(AcceptRecordPolicy) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setAgeUnit(TimeUnit) - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationCriteriaFactoryBean

setAttributes(Object) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

setBatchEngine(BatchEngine) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setBatchEngine(BatchEngine) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setBatchEngine(BatchEngine) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setBatchEngine(BatchEngine) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

setBatchJobInstanceSchedulingStrategy(BatchJobInstanceSchedulingStrategy) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setBatchQueueManager(BatchQueueManager) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

setBatchStepAggregator(DefaultBatchStepAggregator) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setBlockSize(int) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Sets the size of the record block this transaction is processingh

setBlockSize(int) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

setBlockSize(int) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Sets the size of the record block this transaction is processingh

setCompletionCallback(RecordCompletionTracker) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

setCriteria(HistoryExpirationCriteria) - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationPolicyFactoryBean

setCurrentStepId(String) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

setExceptionReporter(StepExceptionReporter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

Allows to customize how the exceptions are reported

setExceptionReporter(StepExceptionReporter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setExceptionReporter(StepExceptionReporter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setExceptionReporter(StepExceptionReporter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

setExpressionManager(ExpressionManager) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setHistoryExpirationFrequency(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

setHistoryExpirationPolicy(HistoryExpirationPolicy) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setInputPhaseException(Exception) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Sets an Exception thrown in the input phase

setInputPhaseException(Exception) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Sets an Exception thrown in the input phase

setJob(BatchJobAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setJobInstanceIdExpression(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setJobInstanceStore(BatchJobInstanceStore) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

setLast(boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setLoadingPhaseException(Exception) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Sets an Exception thrown in the loading phase

setLoadingPhaseException(Exception) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Sets an Exception thrown in the loading phase

setMaxAge(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.config.HistoryExpirationCriteriaFactoryBean

setMaxConcurrency(int) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setMaxFailedRecords(int) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setMessageProcessors(List<Processor>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchMessageBlock

setMessageProcessors(List<Processor>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setMessageProcessors(List<Processor>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setMuleContext(MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

setMuleContext(MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

setMuleContext(MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

setMuleContext(MuleContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

setName(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setNextStep(BatchStep) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setNotificationDispatcher(NotificationDispatcher) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

setNotificationDispatcher(NotificationDispatcher) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setOnCompleteBlock(BatchMessageBlock) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setOnCompletePhaseException(Exception) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Sets an Exception thrown in the on complete phase

setOnCompletePhaseException(Exception) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Sets an Exception thrown in the on complete phase

setPayload(TypedValue<Object>) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

setPayload(TypedValue<Object>, TypedValue<Object>) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

setPayload(Object) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

setPreserveMimeTypes(boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setQueueManager(QueueManager) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

setQueueName(String) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter

sets the name of the queue that this instance uses to pipeline its records

setQueueName(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

sets the name of the queue that this instance uses to pipeline its records

setQueueTimeout(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

setRecordCount(long) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter

Sets the number of records this instance is bound to process

setRecordCount(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

Sets the number of records this instance is bound to process

setRecordProcessors(BatchRecordProcessors) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setSize(Integer) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setStatus(BatchJobInstanceStatus) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter

Sets the status for this instance

setStatus(BatchJobInstanceStatus) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobInstance

Sets the status for this instance

setStep(BatchStepAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setSteps(List<BatchStepAdapter>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.BatchRecordProcessors

setStreaming(boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

setTarget(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setTargetValue(String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

setTotalRecords(long) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

sets the amount of total records that make for the owning BatchJobInstance

setTotalRecords(long) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

sets the amount of total records that make for the owning BatchJobInstance

setVars(Map<String, Object>) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.RecordELAdapter

shouldExpire(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.engine.history.HistoryExpirationCriteria

Determines if jobInstance should be expired from the historic records based on the relationship between BatchJobInstance.getCreationTime() and HistoryExpirationCriteria.maxAge/HistoryExpirationCriteria.ageUnit

shouldExpire(BatchJobInstance) - Method in class com.mulesoft.mule.runtime.module.batch.engine.history.HistoryExpirationPolicy

Determines if the jobInstance should be expired from the historic records.

singleAckAndCommitIfNecessary(BatchTransactionContext) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

size(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.BatchStepAggregator

size(BatchTransactionContext) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueDelegate

Returns the size of the underlying queue

size(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStepAggregator

size(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.BatchContextTransactionRecorder

Returns the size of the not flushed records.

size(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorTransactionRecordBuffer

size(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

Returns how many records are buffered for the given BatchJobInstanceAdapter

size(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

Returns how many records are buffered for the given BatchJobInstanceAdapter

size(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

size(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

Returns how many records are buffered for the given BatchJobInstanceAdapter

size(BatchTransactionContext) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

Returns the size of the underlying queue

size() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.ManagedBatchTransactionContextProvider

For monitoring purposes.

splitAndLoad(BatchJob, BatchJobInstanceAdapter, CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.BatchQueueLoader

start() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchRecordDispatcher

Starts the queue monitoring.

start() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

start() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

start() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

start() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

start() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchRecordDispatcher

start() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

startClock() - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Starts tracking the time that a BatchJobInstance has been processing since the moment that this method has been invoked.

startClock() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Starts tracking the time that a BatchJobInstance has been processing since the moment that this method has been invoked.

startExecution(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Starts asynchronous execution of the given BatchJobInstanceAdapter.

startExecution(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Starts asynchronous execution of the given BatchJobInstanceAdapter.

step - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractStreamingAggregatorQueueBuffer

step - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

step - Variable in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractStreamingAggregatorQueueDelegate

STEP_AGGREGATOR_END - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

STEP_AGGREGATOR_FAILED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

STEP_AGGREGATOR_START - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

STEP_JOB_END - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

STEP_RECORD_END - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

STEP_RECORD_FAILED - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

STEP_RECORD_START - Static variable in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

StepExceptionReporter - Class in com.mulesoft.mule.runtime.module.batch.reporting

StepExceptionReporter(BatchStep, Logger) - Constructor for class com.mulesoft.mule.runtime.module.batch.reporting.StepExceptionReporter

steppingQueue(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

Stepping queues are the ones used to move a Record from one BatchStep to the next.

steppingQueue(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

Stepping queues are the ones used to move a Record from one BatchStep to the next.

SteppingQueueBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of TransactionalQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)

SteppingQueueBuffer(BatchEngine) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.SteppingQueueBuffer

SteppingQueueDelegate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Implementation of AbstractBatchQueueDelegate which accepts a list of BatchProcessingListener to be invoked when SteppingQueueDelegate.dispatch(com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, java.util.Collection) finishes successfully

SteppingQueueDelegate(BatchJobInstanceAdapter, QueueManager, long, ObjectSerializer, MuleContext, List<BatchProcessingListener>) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.SteppingQueueDelegate

stop(String, String) - Method in interface com.mulesoft.mule.runtime.module.batch.api.BatchManager

Stops the BatchJobInstance of the given ids.

stop() - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchRecordDispatcher

Stops monitoring.

stop() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

stop(String, String) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchManager

Stops the BatchJobInstance of the given ids.

stop() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchStep

stop() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.BatchRecordDispatcherDelegate

stop() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

stop() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchRecordDispatcher

stop() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

stopClock() - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Signals that the owning BatchJobInstance has stopped processing at the time this method was invoked

stopClock() - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Signals that the owning BatchJobInstance has stopped processing at the time this method was invoked

stopExecution(BatchJobInstanceAdapter, boolean) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

Stops the execution of the given BatchJobInstanceAdapter.

stopExecution(BatchJobInstanceAdapter, boolean) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

Stops the execution of the given BatchJobInstanceAdapter.

stopMonitoring() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.history.DefaultHistoryExpirationMonitor

Shutdowns the scheduler that executes the expiration tasks.

stopMonitoring() - Method in interface com.mulesoft.mule.runtime.module.batch.internal.engine.history.HistoryExpirationMonitor

Stops monitoring and disposal of historic job instances

store(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Stores the given job instance

store(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

Stores the given job instance

storeFailedRecords(BatchJobInstanceAdapter, Collection<Record>) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

Adds the given Records to the list of failed records

storeFailedRecords(BatchJobInstanceAdapter, Collection<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

Adds the given Records to the list of failed records

StreamingAggregatorBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

An implementation of AggregatorRecordBuffer for streaming instances of DefaultBatchStepAggregator.

StreamingAggregatorBuffer(BatchEngine, BatchStepAdapter, Processor, NotificationDispatcher, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorBuffer

streamingAggregatorInputQueue(BatchJobInstanceAdapter, BatchStepAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

Returns a BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator

streamingAggregatorInputQueue(BatchJobInstanceAdapter, BatchStepAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

Returns a BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator

StreamingAggregatorInputQueueBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of AbstractStreamingAggregatorQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.streamingAggregatorInputQueue(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter)

StreamingAggregatorInputQueueBuffer(BatchEngine, BatchStepAdapter) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorInputQueueBuffer

StreamingAggregatorInputQueueDelegate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Implementation of AbstractStreamingAggregatorQueueDelegate for a streaming aggregator input queue

StreamingAggregatorInputQueueDelegate(BatchJobInstanceAdapter, QueueManager, long, BatchStepAdapter, ObjectSerializer, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.StreamingAggregatorInputQueueDelegate

StreamingAggregatorIteratorWrapper - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Iterator to be used as the payload of an streaming aggregator.

StreamingAggregatorIteratorWrapper(Iterator<List<Record>>, BatchTransactionContextProvider, BatchTransactionContext, BatchJobInstanceAdapter, RecordBuffer, int) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorIteratorWrapper

streamingAggregatorOutputQueue(BatchJobInstanceAdapter, BatchStepAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.queue.BatchQueueManager

Returns a BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator

streamingAggregatorOutputQueue(BatchJobInstanceAdapter, BatchStepAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.DefaultBatchQueueManager

Returns a BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator

StreamingAggregatorOutputQueueBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of AbstractStreamingAggregatorQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.streamingAggregatorOutputQueue(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter)

StreamingAggregatorOutputQueueBuffer(BatchEngine, BatchStepAdapter) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.StreamingAggregatorOutputQueueBuffer

StreamingAggregatorOutputQueueDelegate - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

StreamingAggregatorOutputQueueDelegate(BatchJobInstanceAdapter, QueueManager, long, BatchStepAdapter, ObjectSerializer, MuleContext) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.StreamingAggregatorOutputQueueDelegate

submitWork(Runnable, Runnable, Runnable) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobAdapter

Schedules the given work to be executed.

submitWork(Runnable, Runnable, Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJob

T

thenAccept(Consumer<? super Void>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenAcceptAsync(Consumer<? super Void>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenAcceptAsync(Consumer<? super Void>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenAcceptBoth(CompletionStage<? extends U>, BiConsumer<? super Void, ? super U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenAcceptBothAsync(CompletionStage<? extends U>, BiConsumer<? super Void, ? super U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenAcceptBothAsync(CompletionStage<? extends U>, BiConsumer<? super Void, ? super U>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenApply(Function<? super Void, ? extends U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenApplyAsync(Function<? super Void, ? extends U>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenApplyAsync(Function<? super Void, ? extends U>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenCombine(CompletionStage<? extends U>, BiFunction<? super Void, ? super U, ? extends V>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenCombineAsync(CompletionStage<? extends U>, BiFunction<? super Void, ? super U, ? extends V>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenCombineAsync(CompletionStage<? extends U>, BiFunction<? super Void, ? super U, ? extends V>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenCompose(Function<? super Void, ? extends CompletionStage<U>>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenComposeAsync(Function<? super Void, ? extends CompletionStage<U>>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenComposeAsync(Function<? super Void, ? extends CompletionStage<U>>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenRun(Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenRunAsync(Runnable) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

thenRunAsync(Runnable, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

toBatchException(Exception, BatchJobInstanceAdapter) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

toCompletableFuture() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

toRecord(CoreEvent, Object) - Static method in class com.mulesoft.mule.runtime.module.batch.util.BatchUtils

toString() - Method in class com.mulesoft.mule.runtime.module.batch.api.notification.BatchNotification

toString() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.history.DefaultHistoryExpirationMonitor

toString() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

toString() - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.threading.BatchRecordWork

TransactionalQueueBuffer - Class in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Implementation of RecordBuffer that writes to a Queue when flushed.

TransactionalQueueBuffer(String, BatchEngine) - Constructor for class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

tryFlush(BatchTransactionContext, List<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.BatchContextTransactionRecorder

Attempts to flush records and update statistics.

U

update(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceStore

updates the given job instance.

update(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchJobInstanceStore

updates the given job instance.

updateFor(BatchJobAdapter, Collection<Record>) - Method in interface com.mulesoft.mule.runtime.module.batch.internal.BatchJobResultAdapter

Updates the values in this instance

updateFor(BatchJobAdapter, Collection<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

Updates the values in this instance

updateJobInstance(BatchJobInstanceAdapter) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext

Refreshes the state of the related BatchJobInstanceAdapter

updateJobInstance(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.BaseBatchTransactionContextWrapper

updateJobInstance(BatchJobInstanceAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.transaction.DefaultBatchTransactionContext

Refreshes the state of the related BatchJobInstanceAdapter

updateStatisticsAndRoute(BatchTransactionContext, List<Record>) - Method in interface com.mulesoft.mule.runtime.module.batch.engine.BatchEngine

updateStatisticsAndRoute(BatchTransactionContext, List<Record>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.DefaultBatchEngine

updateWith(CoreEvent) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

updateWith(RecordELAdapter) - Method in class com.mulesoft.mule.runtime.module.batch.api.record.Record

W

whenComplete(BiConsumer<? super Void, ? super Throwable>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

whenCompleteAsync(BiConsumer<? super Void, ? super Throwable>) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

whenCompleteAsync(BiConsumer<? super Void, ? super Throwable>, Executor) - Method in class com.mulesoft.mule.runtime.module.batch.internal.engine.RecordCompletableFuture

A B C D E F G H I J L M N O P R S T U W