org.nuxeo.ecm.platform.mqueues

Class MQServiceImpl

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.ecm.platform.mqueues.MQServiceImpl

All Implemented Interfaces:

MQService, Adaptable, Component, Extensible, TimestampedService

public class MQServiceImpl
extends DefaultComponent
implements MQService

Since:

9.3

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	MQServiceImpl.ComponentsLifeCycleListener

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,ComputationManager>	computationManagers
protected Map<String,ConfigDescriptor>	configs
protected Map<String,MQManager>	managers
protected static String	MQ_CONFIG_XP
protected static String	MQ_TOPOLOGY_XP
static String	NUXEO_MQUEUE_DIR_PROP
static String	NUXEO_MQUEUE_RET_DURATION_PROP
protected Map<String,TopologyDescriptor>	topologies

Fields inherited from class org.nuxeo.runtime.model.DefaultComponent

lastModified

Constructor Summary

Constructors

Constructor and Description
MQServiceImpl()

Method Summary

Modifier and Type	Method and Description
protected void	closeManagers()
protected MQManager	createChronicleMQManager(ConfigDescriptor config)
protected MQManager	createKafkaMQManager(ConfigDescriptor config)
protected void	createMQueueIfNotExists(String name, ConfigDescriptor config)
int	getApplicationStartedOrder() The component notification order for Component.applicationStarted(org.nuxeo.runtime.model.ComponentContext).
protected Path	getChroniclePath(String basePath, String name)
protected String	getChronicleRetention(String retention)
MQManager	getManager(String name) Get a MQManager corresponding to the config name.
protected void	initComputations(String name, TopologyDescriptor descriptor)
void	registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor)
void	start(ComponentContext context) Start the component.
protected void	startComputations()
void	stop(ComponentContext context) Stop the component.
protected void	stopComputations()

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

activate, deactivate, getAdapter, getLastModified, registerExtension, setLastModified, setModifiedNow, unregisterContribution, unregisterExtension

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.runtime.model.Component

applicationStarted

Field Detail

NUXEO_MQUEUE_DIR_PROP

public static final String NUXEO_MQUEUE_DIR_PROP

See Also:

Constant Field Values

NUXEO_MQUEUE_RET_DURATION_PROP

public static final String NUXEO_MQUEUE_RET_DURATION_PROP

See Also:

Constant Field Values

MQ_CONFIG_XP

protected static final String MQ_CONFIG_XP

See Also:

Constant Field Values

MQ_TOPOLOGY_XP

protected static final String MQ_TOPOLOGY_XP

See Also:

Constant Field Values

configs

protected Map<String,ConfigDescriptor> configs

managers

protected Map<String,MQManager> managers

computationManagers

protected Map<String,ComputationManager> computationManagers

topologies

protected Map<String,TopologyDescriptor> topologies

Constructor Detail

MQServiceImpl

public MQServiceImpl()

Method Detail

getApplicationStartedOrder

public int getApplicationStartedOrder()

Description copied from interface: Component

The component notification order for Component.applicationStarted(org.nuxeo.runtime.model.ComponentContext).

Components are notified in increasing order. Order 1000 is the default order for components that don't care. Order 100 is the repository initialization.

Specified by:

getApplicationStartedOrder in interface Component

Returns:

the order, 1000 by default

getManager

public MQManager getManager(String name)

Description copied from interface: MQService

Get a MQManager corresponding to the config name. The service take care of closing the manager on shutdown you should not do it directly.

Specified by:

getManager in interface MQService

createKafkaMQManager

protected MQManager createKafkaMQManager(ConfigDescriptor config)

createChronicleMQManager

protected MQManager createChronicleMQManager(ConfigDescriptor config)

getChronicleRetention

protected String getChronicleRetention(String retention)

getChroniclePath

protected Path getChroniclePath(String basePath,
                                String name)

createMQueueIfNotExists

protected void createMQueueIfNotExists(String name,
                                       ConfigDescriptor config)

start

public void start(ComponentContext context)

Description copied from interface: Component

Start the component. This method is called after all the components were resolved and activated

Specified by:

start in interface Component

Overrides:

start in class DefaultComponent

initComputations

protected void initComputations(String name,
                                TopologyDescriptor descriptor)

stop

public void stop(ComponentContext context)
          throws InterruptedException

Description copied from interface: Component

Stop the component.

Specified by:

stop in interface Component

Overrides:

stop in class DefaultComponent

Throws:

InterruptedException

startComputations

protected void startComputations()

stopComputations

protected void stopComputations()

closeManagers

protected void closeManagers()

registerContribution

public void registerContribution(Object contribution,
                                 String extensionPoint,
                                 ComponentInstance contributor)

Overrides:

registerContribution in class DefaultComponent