org.nuxeo.runtime.stream

Class StreamServiceImpl

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.runtime.stream.StreamServiceImpl

All Implemented Interfaces:

Adaptable, Component, Extensible, TimestampedService, StreamService

public class StreamServiceImpl
extends DefaultComponent
implements StreamService

Since:

9.3

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StreamServiceImpl.ComponentsLifeCycleListener

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,LogConfigDescriptor>	configs
protected static String	LOG_CONFIG_XP
protected Map<String,LogManager>	managers
static String	NUXEO_STREAM_DIR_PROP
static String	NUXEO_STREAM_RET_DURATION_PROP
protected Map<String,StreamProcessorDescriptor>	processorDescriptors
protected Map<String,StreamProcessor>	processors
protected static String	STREAM_PROCESSOR_XP

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

lastModified

Constructor Summary

Constructors

Constructor and Description
StreamServiceImpl()

Method Summary

Modifier and Type	Method and Description
protected void	closeLogManagers()
protected LogManager	createChronicleLogManager(LogConfigDescriptor config)
protected LogManager	createKafkaLogManager(LogConfigDescriptor config)
protected void	createStreamIfNotExists(String name, LogConfigDescriptor 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)
LogManager	getLogManager(String name) Get a LogManager corresponding to the config name.
protected void	initProcessor(String name, StreamProcessorDescriptor 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()
void	unregisterContribution(Object contribution, String extensionPoint, ComponentInstance contributor)

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

activate, deactivate, getAdapter, getLastModified, registerExtension, setLastModified, setModifiedNow, 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_STREAM_DIR_PROP

public static final String NUXEO_STREAM_DIR_PROP

See Also:

Constant Field Values

NUXEO_STREAM_RET_DURATION_PROP

public static final String NUXEO_STREAM_RET_DURATION_PROP

See Also:

Constant Field Values

LOG_CONFIG_XP

protected static final String LOG_CONFIG_XP

See Also:

Constant Field Values

STREAM_PROCESSOR_XP

protected static final String STREAM_PROCESSOR_XP

See Also:

Constant Field Values

configs

protected final Map<String,LogConfigDescriptor> configs

managers

protected final Map<String,LogManager> managers

processors

protected final Map<String,StreamProcessor> processors

processorDescriptors

protected final Map<String,StreamProcessorDescriptor> processorDescriptors

Constructor Detail

StreamServiceImpl

public StreamServiceImpl()

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

getLogManager

public LogManager getLogManager(String name)

Description copied from interface: StreamService

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

Specified by:

getLogManager in interface StreamService

createKafkaLogManager

protected LogManager createKafkaLogManager(LogConfigDescriptor config)

createChronicleLogManager

protected LogManager createChronicleLogManager(LogConfigDescriptor config)

getChronicleRetention

protected String getChronicleRetention(String retention)

getChroniclePath

protected Path getChroniclePath(String basePath,
                                String name)

createStreamIfNotExists

protected void createStreamIfNotExists(String name,
                                       LogConfigDescriptor 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

initProcessor

protected void initProcessor(String name,
                             StreamProcessorDescriptor 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()

closeLogManagers

protected void closeLogManagers()

registerContribution

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

Overrides:

registerContribution in class DefaultComponent

unregisterContribution

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

Overrides:

unregisterContribution in class DefaultComponent