Programmatically creating tcp appender

[GabrielJuliao]

Is there a way to create a TCP appender programmatically?

[philsttr]

Yes, you would follow the same approach as the answers to this Stack Overflow question regarding logback programmatic configuration, but instead of constructing and configuring those other appenders, you would construct and configure a LogstashTcpSocketAppender. The xml element names seen in the readme correlate to setter/adder methods on the appender and its nested objects.

[GabrielJuliao]

Thanks @philsttr phillsttr! How do I get LogstashTcpSocketAppender from the context?

I'm able to get logback core SSL appender like this:

LoggerContext ctx = (LoggerContext) LoggerFactory.getILoggerFactory(); Appender<ILoggingEvent> appender = ctx.getLogger("ROOT").getAppender("SSL_APPENDER");
but the return type of getAppender is Appender<ILoggingEvent>

basically what I need to do is stop and start the appender to reload the Keystore/Truststore, I can do this with SSLSocketAppender.

[GabrielJuliao]

This is my code to reload the appender:

    @GetMapping("/restart")
    public ResponseEntity<?> restart() {
        LoggerContext ctx = (LoggerContext) LoggerFactory.getILoggerFactory();
        Appender<ILoggingEvent> appender = ctx.getLogger("ROOT").getAppender("SSL_APPENDER");
        if (Objects.nonNull(appender)) {
            logger.info("Stopping appender");
            appender.stop();
            try {
                logger.info("Starting appender");
                appender.start();
            } catch (Exception e) {
                logger.error("Error starting appender: " + e.getMessage(), e);
                return ResponseEntity.status(500).build();
            }
            return ResponseEntity.ok().build();
        }

        logger.info("Appender not found");
        return ResponseEntity.notFound().build();
    }

I'm trying to downcast, but getting inconvertible types...

[philsttr]

what does the definition of SSL_APPENDER look like? Is it defined as a LogstashTcpSocketAppender?

[GabrielJuliao]

`

<property name="LOG_PATTERN" value="%d{yyyy-MM-dd HH:mm:ss.SSSZZ} %5p ${PID:- } --- [%15.15t] %-40.40logger{39} : %m%n"/>
<appender name="CONSOLE_APPENDER" class="ch.qos.logback.core.ConsoleAppender">
    <encoder>
        <Pattern>${LOG_PATTERN}</Pattern>
    </encoder>
</appender>

<appender name="SSL_APPENDER" class="net.logstash.logback.appender.LogstashAccessTcpSocketAppender">
    <destination>localhost:8000</destination>
    <reconnectionDelay>2 seconds</reconnectionDelay>
    <!-- Enable SSL and use a different truststore -->
    <ssl>
        <keyStore>
            <location>${C_TCP_LOGGING_KEYSTORE}</location>
            <password>${C_TCP_LOGGING_KEYSTORE_PASSWORD}</password>
        </keyStore>
        <trustStore>
            <location>${C_TCP_LOGGING_TRUSTSTORE}</location>
            <password>${C_TCP_LOGGING_TRUSTSTORE_PASSWORD}</password>
        </trustStore>
    </ssl>
    <encoder>
        <Pattern>${LOG_PATTERN}</Pattern>
    </encoder>
</appender>

<root level="INFO">
    <appender-ref ref="SSL_APPENDER"/>
    <appender-ref ref="CONSOLE_APPENDER"/>
</root>

`

[GabrielJuliao]

I was able to do the downcast but for some reason it does not refresh keystore/truststore even if you create new ones. The code above works for SSLSocketAppender, and keystore/truststore are refreshed.

[GabrielJuliao]

@philsttr Thanks for you help! I was able to reload the Keystore by simply stopping the appender then setting the socket factory to null and starting again!!!