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

Class SteppingQueueDelegate

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

com.mulesoft.mule.runtime.module.batch.internal.engine.queue.SteppingQueueDelegate

All Implemented Interfaces:

BatchQueueDelegate

public class SteppingQueueDelegate
extends AbstractBatchQueueDelegate

Implementation of AbstractBatchQueueDelegate which accepts a list of BatchProcessingListener to be invoked when dispatch(com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, java.util.Collection) finishes successfully

Since:

3.5.0

Field Summary

Fields inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

jobInstance

Constructor Summary

Constructors

Constructor and Description
SteppingQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext, List<BatchProcessingListener> listeners)

Method Summary

Modifier and Type	Method and Description
protected String	buildQueueName() Implementors uses this method to construct the name of the underlying queue
void	dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager manager) Writes the given records into the queue and commits the transaction

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.queue.AbstractBatchQueueDelegate

dispose, getQueueName, iterator, poll, size

Methods inherited from class java.lang.Object

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

Constructor Detail

SteppingQueueDelegate

public SteppingQueueDelegate(BatchJobInstanceAdapter jobInstance,
                             org.mule.runtime.core.api.util.queue.QueueManager queueManager,
                             long queueTimeout,
                             org.mule.runtime.api.serialization.ObjectSerializer serializer,
                             org.mule.runtime.core.api.MuleContext muleContext,
                             List<BatchProcessingListener> listeners)

Method Detail

dispatch

public void dispatch(BatchTransactionContext ctx,
                     Collection<Record> records)
              throws org.mule.runtime.api.exception.MuleException

Writes the given records into the queue

Specified by:

dispatch in interface BatchQueueDelegate

Overrides:

dispatch in class AbstractBatchQueueDelegate

Parameters:

ctx - a BatchTransactionContext which links to the transaction existing on the queue to be written on

records - a list of Record

Throws:

org.mule.runtime.api.exception.MuleException

buildQueueName

protected String buildQueueName()

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

Specified by:

buildQueueName in class AbstractBatchQueueDelegate

Returns:

a non-empty String

dispatchAndCommit

public void dispatchAndCommit(BatchTransactionContext ctx,
                              BatchJobInstanceAdapter jobInstance,
                              List<Record> records,
                              BatchContextTransactionManager manager)

Description copied from interface: BatchQueueDelegate

Writes the given records into the queue and commits the transaction

Specified by:

dispatchAndCommit in interface BatchQueueDelegate

Overrides:

dispatchAndCommit in class AbstractBatchQueueDelegate

Parameters:

ctx - a BatchTransactionContext which links to the transaction existing on the queue to be written on

jobInstance - a job instance

records - a list of Record

manager - performs logic associated with batch transaction