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

Class LoadingQueueBuffer

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

All Implemented Interfaces:

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

public class LoadingQueueBuffer
extends InMemoryRecordBuffer

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

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
LoadingQueueBuffer(BatchQueueManager batchQueueManager, int blockSize, org.mule.runtime.api.notification.NotificationDispatcher notificationFirer)

Method Summary

Modifier and Type	Method and Description
protected void	doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Implement this logic to perform specific flushing logic

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

add, flush, flushAndForget, forget, 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

LoadingQueueBuffer

public LoadingQueueBuffer(BatchQueueManager batchQueueManager,
                          int blockSize,
                          org.mule.runtime.api.notification.NotificationDispatcher notificationFirer)

Method Detail

doFlush

protected void doFlush(BatchJobInstanceAdapter jobInstance,
                       com.google.common.collect.Multimap<BatchTransactionContext,Record> records)

Description copied from class: InMemoryRecordBuffer

Implement this logic to perform specific flushing logic

Specified by:

doFlush in class InMemoryRecordBuffer

Parameters:

jobInstance - a BatchJobInstanceAdapter

records - a Multimap relating a BatchTransactionContext to its corresponding buffered Records