Java logging

LogHelper.java

public class LogHelper {
    public static <T> Consumer<Signal<T>> info(Logger logger, String logStatement, Object... arguments) {
        return signal -> {
            if (signal.isOnNext()) {
                info(logger, logStatement, signal.getContextView(), arguments);
            }
        };
    }
    
    public static void info(Logger logger,String logStatement, ContextView ctx, Object... arguments) {
        var requestId = (String) ctx.get("requestId");

        try (MDC.MDCCloseable ignored = MDC.putCloseable("requestId", requestId)) {
            logger.info(logStatement, arguments);
        }
    }
}