@@ -0,0 +1,1037 @@
+package org.textfiledatatools.core.message;%0A%0Aimport org.textfiledatatools.core.Record;%0Aimport org.textfiledatatools.core.message.supplier.LocalTimeSupplier;%0Aimport org.textfiledatatools.core.message.supplier.ThreadNameSupplier;%0A%0Aimport java.util.Objects;%0Aimport java.util.function.Supplier;%0A%0A/**%0A * @author Mathias Kalb%0A * @since 0.1%0A */%0Apublic class SupplierMessage implements RecordMessage%3CRecord%3E %7B%0A%0A    private final Supplier%3CString%3E messageSupplier;%0A%0A    // Supplier must be thread-safe%0A    public SupplierMessage(Supplier%3CString%3E messageSupplier) %7B%0A        Objects.requireNonNull(messageSupplier);%0A        this.messageSupplier = messageSupplier;%0A    %7D%0A%0A    public static final SupplierMessage getLocalTimeSupplier() %7B%0A        return new SupplierMessage(new LocalTimeSupplier());%0A    %7D%0A%0A    public static final SupplierMessage getThreadNameSupplier() %7B%0A        return new SupplierMessage(new ThreadNameSupplier());%0A    %7D%0A%0A    @Override%0A    public String createMessage(Record record) %7B%0A        return messageSupplier.get();%0A    %7D%0A%0A%7D%0A

Add SupplierMessage