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
static String	DEFAULT_CODEC
protected Map<String,LogManager>	managers
static String	NUXEO_STREAM_DIR_PROP
static String	NUXEO_STREAM_RET_DURATION_PROP
protected Map<String,StreamProcessor>	processors
protected static String	XP_LOG_CONFIG
protected static String	XP_STREAM_PROCESSOR

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

lastModified, name

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(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 Settings	getSettings(StreamProcessorDescriptor descriptor)
protected void	initProcessor(StreamProcessorDescriptor descriptor)
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, getDescriptor, getDescriptors, getLastModified, getRegistry, register, registerContribution, registerExtension, setLastModified, setModifiedNow, setName, unregister, 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_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

DEFAULT_CODEC

public static final String DEFAULT_CODEC

See Also:

Constant Field Values

XP_LOG_CONFIG

protected static final String XP_LOG_CONFIG

See Also:

Constant Field Values

XP_STREAM_PROCESSOR

protected static final String XP_STREAM_PROCESSOR

See Also:

Constant Field Values

managers

protected final Map<String,LogManager> managers

processors

protected final Map<String,StreamProcessor> processors

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(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(StreamProcessorDescriptor descriptor)

getSettings

protected Settings getSettings(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()