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

Class FixedAggregatorRecordBuffer

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.FixedAggregatorRecordBuffer

All Implemented Interfaces:

RecordBuffer, org.mule.runtime.api.meta.NamedObject

public class FixedAggregatorRecordBuffer
extends AggregatorRecordBuffer

Implementation of AggregatorRecordBuffer for non streaming DefaultBatchStepAggregator. This buffer works with in memory Record blocks of a fixed size

Since:

3.5.0

Field Summary

Fields inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

batchEngine, exceptionReporter, muleContext, notificationDispatcher, step

Constructor Summary

Constructors

Constructor and Description
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)

Method Summary

Modifier and Type	Method and Description
protected org.mule.runtime.core.api.event.CoreEvent	configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Configures the event (set payload, properties, etc) to is going to be used when flushing the aggregated records through the AggregatorRecordBuffer.chain
void	forget(BatchJobInstanceAdapter jobInstance) For this implementation, to forget means to flush whatever records are currently buffered.
protected BatchProcessingTemplate	makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> contexts, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext) Returns the BatchProcessingTemplate through which AggregatorRecordBuffer.chain will be executed

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AggregatorRecordBuffer

doFlush, getLocation, markError, setExceptionReporter

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.InMemoryRecordBuffer

add, flush, flushAndForget, getHolderLock, size

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

add, getName

Methods inherited from class java.lang.Object

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

Constructor Detail

FixedAggregatorRecordBuffer

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

Method Detail

forget

public void forget(BatchJobInstanceAdapter jobInstance)

For this implementation, to forget means to flush whatever records are currently buffered. This needs to be so that the records are put back into the queue avoiding record loss and/or memory leaks

Specified by:

forget in interface RecordBuffer

Overrides:

forget in class InMemoryRecordBuffer

Parameters:

jobInstance - the BatchJobInstanceAdapter owning the records

configureChainEvent

protected org.mule.runtime.core.api.event.CoreEvent configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event,
                                                                        BatchJobInstanceAdapter jobInstance,
                                                                        com.google.common.collect.Multimap<BatchTransactionContext,Record> records)

Description copied from class: AggregatorRecordBuffer

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

Specified by:

configureChainEvent in class AggregatorRecordBuffer

Parameters:

event - a CoreEvent

jobInstance - the BatchJobInstanceAdapter being executed

records - the aggregated Records

Returns:

a configured CoreEvent or null, which means that the chain should be skipped for this event

makeProcessingTemplate

protected BatchProcessingTemplate makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> contexts,
                                                         org.mule.runtime.core.api.processor.Processor processor,
                                                         org.mule.runtime.core.api.MuleContext muleContext)

Description copied from class: AggregatorRecordBuffer

Returns the BatchProcessingTemplate through which AggregatorRecordBuffer.chain will be executed

Specified by:

makeProcessingTemplate in class AggregatorRecordBuffer

Parameters:

contexts - the aggregated Records

processor - the Processor to be executed

muleContext - the current MuleContext

Returns: