com.mulesoft.mule.runtime.module.cluster.internal.vm

Class ClusterQueueManager

java.lang.Object

org.mule.runtime.core.internal.util.queue.AbstractQueueManager

com.mulesoft.mule.runtime.module.cluster.internal.vm.ClusterQueueManager

All Implemented Interfaces:

ClusterQueueNameResolver, org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable, org.mule.runtime.core.api.context.MuleContextAware, org.mule.runtime.core.api.util.queue.QueueManager, org.mule.runtime.core.internal.util.queue.QueueProvider, org.mule.runtime.core.internal.util.queue.QueueStoreCacheListener

public class ClusterQueueManager
extends org.mule.runtime.core.internal.util.queue.AbstractQueueManager
implements ClusterQueueNameResolver

Field Summary

Fields

Modifier and Type	Field and Description
static String	QUEUE_LABEL

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

PHASE_NAME

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

PHASE_NAME

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
ClusterQueueManager(HazelcastClusterManager hazelcastManager)

Method Summary

Modifier and Type	Method and Description
protected org.mule.runtime.core.internal.util.queue.QueueStore	createQueueStore(String queueName, org.mule.runtime.core.api.util.queue.QueueConfiguration config)
protected void	doDispose()
static String	getQueuePrefix(org.mule.runtime.core.api.MuleContext muleContext)
static String	getQueuePrefix(String appId)
org.mule.runtime.core.api.util.queue.QueueSession	getQueueSession()
org.mule.runtime.core.internal.util.queue.RecoverableQueueStore	getRecoveryQueue(String queueName)
void	initialise()
String	resolveQueueName(String queueName) Creates a unique name for the queue
static String	resolveQueueName(String appId, String queueName)
void	start()
void	stop()

Methods inherited from class org.mule.runtime.core.internal.util.queue.AbstractQueueManager

clearQueueConfiguration, closeQueueStore, dispose, disposeQueueStore, getMuleContext, getQueue, getQueueConfiguration, setDefaultQueueConfiguration, setMuleContext, setQueueConfiguration

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_LABEL

public static final String QUEUE_LABEL

See Also:

Constant Field Values

Constructor Detail

ClusterQueueManager

public ClusterQueueManager(HazelcastClusterManager hazelcastManager)

Method Detail

getQueueSession

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

Specified by:

getQueueSession in interface org.mule.runtime.core.api.util.queue.QueueManager

Returns:

an instance of ClusterQueueSession

start

public void start()
           throws org.mule.runtime.api.exception.MuleException

Specified by:

start in interface org.mule.runtime.api.lifecycle.Startable

Throws:

org.mule.runtime.api.exception.MuleException

stop

public void stop()
          throws org.mule.runtime.api.exception.MuleException

Specified by:

stop in interface org.mule.runtime.api.lifecycle.Stoppable

Throws:

org.mule.runtime.api.exception.MuleException

createQueueStore

protected org.mule.runtime.core.internal.util.queue.QueueStore createQueueStore(String queueName,
                                                                                org.mule.runtime.core.api.util.queue.QueueConfiguration config)

Specified by:

createQueueStore in class org.mule.runtime.core.internal.util.queue.AbstractQueueManager

doDispose

protected void doDispose()

Specified by:

doDispose in class org.mule.runtime.core.internal.util.queue.AbstractQueueManager

getRecoveryQueue

public org.mule.runtime.core.internal.util.queue.RecoverableQueueStore getRecoveryQueue(String queueName)

Specified by:

getRecoveryQueue in interface org.mule.runtime.core.internal.util.queue.QueueProvider

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

resolveQueueName

public String resolveQueueName(String queueName)

Description copied from interface: ClusterQueueNameResolver

Creates a unique name for the queue

Specified by:

resolveQueueName in interface ClusterQueueNameResolver

Parameters:

queueName - logical queue name

Returns:

real queue name in the shared data grid

getQueuePrefix

public static String getQueuePrefix(org.mule.runtime.core.api.MuleContext muleContext)

getQueuePrefix

public static String getQueuePrefix(String appId)

resolveQueueName

public static String resolveQueueName(String appId,
                                      String queueName)