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

Class BatchLockFactory

java.lang.Object

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

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Initialisable

public class BatchLockFactory
extends Object
implements org.mule.runtime.api.lifecycle.Initialisable

Consumer of LockProvider for the batch module. Because batch jobs are not distributed accross the cluster when running in HA, that means that Batch locks also need to not be distributed. Because of that, batch can't use the default LockFactory from the Registry when running in HA.

This implementation will always return a local Lock that batch can safely use in any scenario

Since:

3.5.0

Field Summary

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

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
BatchLockFactory()

Method Summary

Modifier and Type	Method and Description
Lock	createLock(String lockId) Provides a lock to create thread safe Mule components.
void	initialise()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchLockFactory

public BatchLockFactory()

Method Detail

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

createLock

public Lock createLock(String lockId)

Provides a lock to create thread safe Mule components.

Always returns the same lock for a certain lockId

Parameters:

lockId - ID of the lock. Non null.

Returns:

a Lock instance associated to the lockId