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

Class AbstractRecordBuffer

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

InMemoryRecordBuffer, TransactionalQueueBuffer

public abstract class AbstractRecordBuffer
extends Object
implements RecordBuffer

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

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
AbstractRecordBuffer(String name)

Method Summary

Modifier and Type	Method and Description
int	add(BatchJobInstanceAdapter jobInstance, BatchTransactionContextProvider ctxProvider, Record record) Invokes RecordBuffer.add(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, Record) using the BatchTransactionContext returned by the context provider
String	getName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.RecordBuffer

add, flush, flushAndForget, forget, size

Constructor Detail

AbstractRecordBuffer

public AbstractRecordBuffer(String name)

Method Detail

add

public int add(BatchJobInstanceAdapter jobInstance,
               BatchTransactionContextProvider ctxProvider,
               Record record)

Invokes RecordBuffer.add(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, Record) using the BatchTransactionContext returned by the context provider

Specified by:

add in interface RecordBuffer

Parameters:

jobInstance - a BatchJobInstanceAdapter

ctxProvider - a BatchTransactionContextProvider

record - a Record

Returns:

how many records are still buffered for the given job instance

getName

public String getName()

Specified by:

getName in interface org.mule.runtime.api.meta.NamedObject