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

Class SwitchingClusterQueueManager

java.lang.Object

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

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.api.lifecycle.Lifecycle, org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable, org.mule.runtime.core.api.util.queue.QueueManager

public class SwitchingClusterQueueManager
extends Object
implements org.mule.runtime.core.api.util.queue.QueueManager, org.mule.runtime.api.lifecycle.Lifecycle

A QueueManager that wraps a ClusterQueueManager but accounts for the possibility of the MuleConfiguration object disabling distributed queues. In which case, we fallback to the local queue manager.

The actual QueueManager to be used is resolved in the initialise() phase, after which this instance becomes immutable.

Since:

4.0

Field Summary

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

PHASE_NAME

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

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
SwitchingClusterQueueManager(ClusterQueueManager clusterQueueManager, ClusterStoreProfile defaultClusterStoreProfile)

Method Summary

Modifier and Type	Method and Description
void	dispose()
Optional<org.mule.runtime.core.api.util.queue.QueueConfiguration>	getQueueConfiguration(String queueName)
org.mule.runtime.core.api.util.queue.QueueSession	getQueueSession()
void	initialise()
void	setDefaultQueueConfiguration(org.mule.runtime.core.api.util.queue.QueueConfiguration config)
void	setQueueConfiguration(String queueName, org.mule.runtime.core.api.util.queue.QueueConfiguration config)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

SwitchingClusterQueueManager

public SwitchingClusterQueueManager(ClusterQueueManager clusterQueueManager,
                                    ClusterStoreProfile defaultClusterStoreProfile)

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

getQueueSession

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

Specified by:

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

setDefaultQueueConfiguration

public void setDefaultQueueConfiguration(org.mule.runtime.core.api.util.queue.QueueConfiguration config)

Specified by:

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

setQueueConfiguration

public void setQueueConfiguration(String queueName,
                                  org.mule.runtime.core.api.util.queue.QueueConfiguration config)

Specified by:

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

getQueueConfiguration

public Optional<org.mule.runtime.core.api.util.queue.QueueConfiguration> getQueueConfiguration(String queueName)

Specified by:

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

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

dispose

public void dispose()

Specified by:

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