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

Class AbstractStreamingAggregatorQueueDelegate

java.lang.Object

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

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

All Implemented Interfaces:

BatchQueueDelegate

Direct Known Subclasses:

StreamingAggregatorInputQueueDelegate, StreamingAggregatorOutputQueueDelegate

public abstract class AbstractStreamingAggregatorQueueDelegate
extends AbstractBatchQueueDelegate

Base class for implementations of AbstractBatchQueueDelegate which depends on a BatchStepAdapter

Since:

3.5.0

Field Summary

Fields

Modifier and Type	Field and Description
protected BatchStepAdapter	step

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

jobInstance

Constructor Summary

Constructors

Constructor and Description
AbstractStreamingAggregatorQueueDelegate(BatchJobInstanceAdapter jobInstance, org.mule.runtime.core.api.util.queue.QueueManager queueManager, long queueTimeout, BatchStepAdapter step, org.mule.runtime.api.serialization.ObjectSerializer serializer, org.mule.runtime.core.api.MuleContext muleContext)

Method Summary

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

buildQueueName, dispatch, dispatchAndCommit, dispose, getQueueName, iterator, poll, size

Methods inherited from class java.lang.Object

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

Field Detail

step

protected final BatchStepAdapter step

Constructor Detail

AbstractStreamingAggregatorQueueDelegate

public AbstractStreamingAggregatorQueueDelegate(BatchJobInstanceAdapter jobInstance,
                                                org.mule.runtime.core.api.util.queue.QueueManager queueManager,
                                                long queueTimeout,
                                                BatchStepAdapter step,
                                                org.mule.runtime.api.serialization.ObjectSerializer serializer,
                                                org.mule.runtime.core.api.MuleContext muleContext)