| Modifier and Type | Method and Description |
|---|---|
BatchEngine |
BatchJobAdapter.getBatchEngine() |
| Modifier and Type | Method and Description |
|---|---|
BatchEngine |
DefaultBatchStep.getBatchEngine() |
BatchEngine |
DefaultBatchJob.getBatchEngine() |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultBatchStep.setBatchEngine(BatchEngine batchEngine) |
void |
DefaultBatchJob.setBatchEngine(BatchEngine batchEngine) |
void |
DefaultBatchStepAggregator.setBatchEngine(BatchEngine batchEngine) |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultBatchEngine
Default implementation of
BatchEngine |
| Constructor and Description |
|---|
BatchRecordDispatcherDelegate(BatchEngine batchEngine,
BatchWorkManager workManager) |
DefaultBatchRecordDispatcher(BatchEngine batchEngine,
BatchWorkManager workManager,
org.mule.runtime.api.scheduler.SchedulerService schedulerService,
org.mule.runtime.api.scheduler.SchedulerConfig schedulerBaseConfig,
org.mule.runtime.api.notification.NotificationListenerRegistry notificationListenerRegistry) |
| Modifier and Type | Field and Description |
|---|---|
protected BatchEngine |
AggregatorRecordBuffer.batchEngine |
| Constructor and Description |
|---|
AbstractStreamingAggregatorQueueBuffer(String name,
BatchEngine batchEngine,
BatchStepAdapter step) |
AggregatorRecordBuffer(String name,
int size,
BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.component.location.ComponentLocation location,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
BatchContextTransactionRecorder(BatchEngine batchEngine) |
FixedAggregatorRecordBuffer(int blockSize,
boolean preserveMimeTypes,
BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.component.location.ComponentLocation location,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
FixedAggregatorTransactionRecordBuffer(int blockSize,
boolean preserveMimeTypes,
BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.component.location.ComponentLocation location,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
SteppingQueueBuffer(BatchEngine batchEngine) |
StreamingAggregatorBuffer(BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
StreamingAggregatorInputQueueBuffer(BatchEngine batchEngine,
BatchStepAdapter step) |
StreamingAggregatorOutputQueueBuffer(BatchEngine batchEngine,
BatchStepAdapter step) |
TransactionalQueueBuffer(String name,
BatchEngine batchEngine) |
| Constructor and Description |
|---|
DefaultHistoryExpirationMonitor(BatchEngine batchEngine,
BatchJobInstanceStore store,
long frequency,
TimeUnit timeUnit,
org.mule.runtime.core.api.MuleContext muleContext) |
| Constructor and Description |
|---|
BatchQueueLoader(BatchEngine batchEngine,
int blockSize,
org.mule.runtime.core.internal.routing.SplittingStrategy<org.mule.runtime.core.api.event.CoreEvent,org.mule.runtime.core.internal.routing.MessageSequence<?>> splittingStrategy,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultBatchWorkManager.setBatchEngine(BatchEngine batchEngine) |
| Constructor and Description |
|---|
BatchJobInstanceTerminatorWork(BatchEngine batchEngine,
BatchJobInstanceAdapter jobInstance) |
BatchRecordWork(BatchEngine batchEngine,
BatchJobAdapter job,
BatchTransactionContext ctx,
BatchProcessingListener listener,
List<Record> block) |
| Constructor and Description |
|---|
DefaultBatchTransactionContextFactory(BatchEngine batchEngine) |
ManagedBatchTransactionContextProvider(BatchEngine batchEngine,
boolean transactional) |
Copyright © 2006–2022 MuleSoft, Inc.. All rights reserved.