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

Class DefaultBatchQueueManager

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

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

All Implemented Interfaces:

BatchProcessingListenersOwner, BatchQueueManager, org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.core.api.context.MuleContextAware

public class DefaultBatchQueueManager
extends BaseBatchProcessingListenerOwner
implements BatchQueueManager, org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.core.api.context.MuleContextAware

Default implementation of BatchQueueManager

Since:

3.5.0

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
DefaultBatchQueueManager()

Method Summary

Modifier and Type	Method and Description
long	brokersSize()
void	dispose()
void	disposeBroker(BatchJobInstanceAdapter jobInstance) Disposes just the broker for the queues.
void	disposeQueues(BatchTransactionContext ctx) Disposes all initialized queues associated to the given BatchJobInstanceAdapter
void	initialise()
org.mule.runtime.core.api.util.queue.QueueSession	newQueueSession()
void	setMuleContext(org.mule.runtime.core.api.MuleContext context)
void	setQueueManager(org.mule.runtime.core.api.util.queue.QueueManager queueManager)
void	setQueueTimeout(long queueTimeout)
BatchQueueDelegate	steppingQueue(BatchJobInstanceAdapter jobInstance) Stepping queues are the ones used to move a Record from one BatchStep to the next.
BatchQueueDelegate	streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance, BatchStepAdapter step) Returns a BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator
BatchQueueDelegate	streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance, BatchStepAdapter step) Returns a BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.BaseBatchProcessingListenerOwner

addBatchProcessingListener, addBatchProcessingListener, getListeners, removeBatchProcessingListener, removeBatchProcessingListener

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

addBatchProcessingListener, addBatchProcessingListener, removeBatchProcessingListener, removeBatchProcessingListener

Constructor Detail

DefaultBatchQueueManager

public DefaultBatchQueueManager()

Method Detail

newQueueSession

public org.mule.runtime.core.api.util.queue.QueueSession newQueueSession()

Specified by:

newQueueSession in interface BatchQueueManager

steppingQueue

public BatchQueueDelegate steppingQueue(BatchJobInstanceAdapter jobInstance)

Stepping queues are the ones used to move a Record from one BatchStep to the next.

Specified by:

steppingQueue in interface BatchQueueManager

Parameters:

jobInstance - the BatchJobInstanceAdapter which records we want to step

Returns:

a BatchQueueDelegate

streamingAggregatorInputQueue

public BatchQueueDelegate streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance,
                                                        BatchStepAdapter step)

Returns a BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator

Specified by:

streamingAggregatorInputQueue in interface BatchQueueManager

Parameters:

jobInstance - the BatchJobInstanceAdapter which records we want to stream

step - the BatchStepAdapter owning the aggregator block

Returns:

a BatchQueueDelegate

streamingAggregatorOutputQueue

public BatchQueueDelegate streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance,
                                                         BatchStepAdapter step)

Returns a BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator

Specified by:

streamingAggregatorOutputQueue in interface BatchQueueManager

Parameters:

jobInstance - the BatchJobInstanceAdapter which records we want to stream

step - the BatchStepAdapter owning the aggregator block

Returns:

a BatchQueueDelegate

disposeQueues

public void disposeQueues(BatchTransactionContext ctx)

Disposes all initialized queues associated to the given BatchJobInstanceAdapter

Specified by:

disposeQueues in interface BatchQueueManager

Parameters:

ctx - a not null BatchTransactionContext

disposeBroker

public void disposeBroker(BatchJobInstanceAdapter jobInstance)

Disposes just the broker for the queues. This will not dispose any queues.

This is just to be used when a dispose is needed before any queues were created.

Specified by:

disposeBroker in interface BatchQueueManager

Parameters:

jobInstance - the instance to dispose the broker for.

brokersSize

public long brokersSize()

Specified by:

brokersSize in interface BatchQueueManager

Returns:

the number of queue brokers that are currently active.

initialise

public void initialise()
                throws org.mule.runtime.api.lifecycle.InitialisationException

Specified by:

initialise in interface org.mule.runtime.api.lifecycle.Initialisable

Throws:

org.mule.runtime.api.lifecycle.InitialisationException

dispose

public void dispose()

Specified by:

dispose in interface org.mule.runtime.api.lifecycle.Disposable

setMuleContext

public void setMuleContext(org.mule.runtime.core.api.MuleContext context)

Specified by:

setMuleContext in interface org.mule.runtime.core.api.context.MuleContextAware

setQueueTimeout

public void setQueueTimeout(long queueTimeout)

setQueueManager

public void setQueueManager(org.mule.runtime.core.api.util.queue.QueueManager queueManager)