Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ void testMetadata() throws Exception {
}

@Test
final void testAdditionalFields() throws Exception {
protected final void testAdditionalFields() throws Exception {
debug("test");
assertThat(getAndValidateLastLogLine().get("key1").textValue()).isEqualTo("value1");
assertThat(getAndValidateLastLogLine().get("key2").textValue()).isEqualTo("value2");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,19 +88,19 @@ public String format(final LogRecord record) {
return builder.toString();
}

protected void setIncludeOrigin(final boolean includeOrigin) {
public void setIncludeOrigin(final boolean includeOrigin) {
this.includeOrigin = includeOrigin;
}

protected void setServiceName(final String serviceName) {
public void setServiceName(final String serviceName) {
this.serviceName = serviceName;
}

protected void setServiceNodeName(final String serviceNodeName) {
public void setServiceNodeName(final String serviceNodeName) {
this.serviceNodeName = serviceNodeName;
}

protected void setStackTraceAsArray(final boolean stackTraceAsArray) {
public void setStackTraceAsArray(final boolean stackTraceAsArray) {
this.stackTraceAsArray = stackTraceAsArray;
}

Expand All @@ -112,6 +112,10 @@ public void setAdditionalFields(String additionalFields) {
this.additionalFields = AdditionalField.parse(additionalFields);
}

public void setAdditionalFields(List<AdditionalField> additionalFields) {
this.additionalFields = additionalFields;
}

private String getProperty(final String name, final String defaultValue) {
String value = LogManager.getLogManager().getProperty(name);
if (value == null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
package co.elastic.logging.jul;

import co.elastic.logging.AbstractEcsLoggingTest;
import co.elastic.logging.AdditionalField;
import co.elastic.logging.ParameterizedLogSupport;
import com.fasterxml.jackson.databind.JsonNode;
import org.junit.jupiter.api.BeforeEach;
Expand All @@ -34,6 +35,7 @@
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.util.List;
import java.util.logging.Formatter;
import java.util.logging.Handler;
import java.util.logging.Level;
Expand Down Expand Up @@ -67,7 +69,7 @@ public void publish(LogRecord record) {
}
}

private final EcsFormatter formatter = new EcsFormatter();
private EcsFormatter formatter;

private final Logger logger = Logger.getLogger("");

Expand Down Expand Up @@ -108,17 +110,22 @@ public JsonNode getLastLogLine() throws IOException {

@BeforeEach
void setUp() {
setUpFormatter();
formatter.setAdditionalFields("key1=value1,key2=value2");
}

private void setUpFormatter() {
clearHandlers();


formatter = new EcsFormatter();
formatter.setIncludeOrigin(true);
formatter.setServiceName("test");
formatter.setServiceNodeName("test-node");
formatter.setEventDataset("testdataset");
formatter.setAdditionalFields("key1=value1,key2=value2");


Handler handler = new InMemoryStreamHandler(out, formatter);
handler.setLevel(Level.ALL);

logger.addHandler(handler);
logger.setLevel(Level.ALL);
}
Expand All @@ -131,11 +138,16 @@ void testLogOrigin() throws Exception {
//No file.line for JUL
}

@Test
void testAdditionalFieldsAsList() throws Exception {
setUpFormatter();
formatter.setAdditionalFields(List.of(new AdditionalField("key1", "value1"), new AdditionalField("key2", "value2")));
super.testAdditionalFields();
}

private void clearHandlers() {
for (Handler handler : logger.getHandlers()) {
logger.removeHandler(handler);
}
}

}