Log4jExecutor.kt

import org.apache.logging.log4j.ThreadContext
import java.util.concurrent.LinkedBlockingQueue
import java.util.concurrent.ThreadPoolExecutor
import java.util.concurrent.TimeUnit

class Log4jExecutor : ThreadPoolExecutor(1, 1,
        0L, TimeUnit.MILLISECONDS,
        LinkedBlockingQueue()) {

    override fun beforeExecute(t: Thread, r: Runnable) {
        refreshKeys()
        super.beforeExecute(t, r)
    }

    private fun refreshKeys() = ThreadContext.putAll(LogEventConstants.getThreadContextKeys())
}