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

Class StreamingAggregatorInputQueueDelegate

java.lang.Object

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

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

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

All Implemented Interfaces:

BatchQueueDelegate

public class StreamingAggregatorInputQueueDelegate
extends AbstractStreamingAggregatorQueueDelegate

Implementation of AbstractStreamingAggregatorQueueDelegate for a streaming aggregator input queue

Since:

3.5.0

Field Summary

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

step

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

jobInstance

Constructor Summary

Constructors

Constructor and Description
StreamingAggregatorInputQueueDelegate(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

Modifier and Type	Method and Description
protected String	buildQueueName() Implementors uses this method to construct the name of the underlying queue

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

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

Constructor Detail

StreamingAggregatorInputQueueDelegate

public StreamingAggregatorInputQueueDelegate(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 Detail

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