Application Performance Monitoring

<dependency>
  <groupId>com.activeviam.springboot</groupId>
  <artifactId>atoti-server-apm-starter</artifactId>
  <version>${project.version}</version>
</dependency>

<?xml version="1.0" encoding="UTF-8"?>
{/* Example LOGBACK Configuration File http://logback.qos.ch/manual/configuration.html */}
<configuration>
    <shutdownHook class="ch.qos.logback.core.hook.DelayingShutdownHook"/>
    <jmxConfigurator/>
    {/* Exposing the conversion rules */}
    <conversionRule conversionWord="thread"
                    converterClass="com.activeviam.apm.api.logging.LogThreadConverter"/>
    <conversionRule conversionWord="user"
                    converterClass="com.activeviam.apm.api.logging.LogUserConverter"/>

    <appender name="MAIN" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${custom.log.dir}/${project.artifactId}.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>${custom.log.dir}/${project.artifactId}_%d{yyyy-MM-dd}.log.gz
            </fileNamePattern>
            <maxHistory>30</maxHistory>
            <cleanHistoryOnStart>true</cleanHistoryOnStart>
        </rollingPolicy>

        <encoder>
            {/* Using the converter in the appender pattern layout */}
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [Thread: %thread; User: %user] %-5level %logger{35} -
                %msg%n
            </pattern>
        </encoder>
    </appender>
    [...]
    <root level="INFO">
        <appender-ref ref="MAIN"/>
    </root>
    <contextListener class="ch.qos.logback.classic.jul.LevelChangePropagator">
        <resetJUL>true</resetJUL>
    </contextListener>
</configuration>

...
@Autowired
private MonitoredDataLoadingConfig monitoredDataLoadingConfig;

@Bean
protected IMessageHandler<IFileInfo<Path>> messageHandler() {
    return monitoredDataLoadingConfig.messageHandler();
}

@Bean(destroyMethod = "close")
public CustomCsvSource dataCsvSource() {
    final CsvSource csvSource = new CsvSource(DATA_TAG);
  ...
    return csvSource;
}

protected List<IStoreMessageChannel<IFileInfo<Path>, ILineReader>> dataCsvChannels(
        final CsvMessageChannelFactory<Path> dataCsvChannelFactory,
        final IMessageHandler<IFileInfo<Path>> messageHandler) {

    final List<IStoreMessageChannel<IFileInfo<Path>, ILineReader>> channels = new ArrayList<>();
    ITuplePublisher<IFileInfo<Path>> tuplePublisher = ...;
    IStoreMessageChannel<IFileInfo<Path>, ILineReader> channel = dataCsvChannelFactory.createChannel(topicName,
            storeName, tuplePublisher);
    channel.withPublisher(tuplePublisher);
    channel.withMessageHandler(messageHandler());
    channels.add(channel);
}