Skip to content

Commit 132aa31

Browse files
otelbot[bot]laurit
andauthored
Review fixes for log4j-mdc-1.2:javaagent (#18196)
Co-authored-by: otelbot <197425009+otelbot@users.noreply.github.com> Co-authored-by: Lauri Tulmin <ltulmin@splunk.com> Co-authored-by: Lauri Tulmin <tulmin@gmail.com>
1 parent 83ad467 commit 132aa31

2 files changed

Lines changed: 40 additions & 34 deletions

File tree

instrumentation/log4j/log4j-mdc-1.2/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/log4j/mdc/v1_2/ListAppender.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212

1313
public class ListAppender extends AppenderSkeleton {
1414

15-
private static final List<LoggingEvent> events = new ArrayList<LoggingEvent>();
15+
private static final List<LoggingEvent> events = new ArrayList<>();
1616

1717
@Override
1818
protected void append(LoggingEvent loggingEvent) {
@@ -27,11 +27,11 @@ public boolean requiresLayout() {
2727
@Override
2828
public void close() {}
2929

30-
public static void clearEvents() {
30+
static void clearEvents() {
3131
events.clear();
3232
}
3333

34-
public static List<LoggingEvent> getEvents() {
34+
static List<LoggingEvent> getEvents() {
3535
return events;
3636
}
3737
}

instrumentation/log4j/log4j-mdc-1.2/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/log4j/mdc/v1_2/Log4j1MdcTest.java

Lines changed: 37 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -36,17 +36,20 @@ void noIdsWhenNoSpan() {
3636
logger.info("log message 2");
3737

3838
List<LoggingEvent> events = ListAppender.getEvents();
39+
assertThat(events)
40+
.extracting(LoggingEvent::getMessage)
41+
.containsExactly("log message 1", "log message 2");
3942

40-
assertThat(events).hasSize(2);
41-
assertThat(events.get(0).getMessage()).isEqualTo("log message 1");
42-
assertThat(events.get(0).getMDC("trace_id")).isNull();
43-
assertThat(events.get(0).getMDC("span_id")).isNull();
44-
assertThat(events.get(0).getMDC("trace_flags")).isNull();
43+
LoggingEvent firstEvent = events.get(0);
44+
LoggingEvent secondEvent = events.get(1);
4545

46-
assertThat(events.get(1).getMessage()).isEqualTo("log message 2");
47-
assertThat(events.get(1).getMDC("trace_id")).isNull();
48-
assertThat(events.get(1).getMDC("span_id")).isNull();
49-
assertThat(events.get(1).getMDC("trace_flags")).isNull();
46+
assertThat(firstEvent.getMDC("trace_id")).isNull();
47+
assertThat(firstEvent.getMDC("span_id")).isNull();
48+
assertThat(firstEvent.getMDC("trace_flags")).isNull();
49+
50+
assertThat(secondEvent.getMDC("trace_id")).isNull();
51+
assertThat(secondEvent.getMDC("span_id")).isNull();
52+
assertThat(secondEvent.getMDC("trace_flags")).isNull();
5053
}
5154

5255
@Test
@@ -70,25 +73,28 @@ void idsWhenSpan() {
7073
});
7174

7275
List<LoggingEvent> events = ListAppender.getEvents();
76+
assertThat(events)
77+
.extracting(LoggingEvent::getMessage)
78+
.containsExactly("log message 1", "log message 2", "log message 3");
79+
80+
LoggingEvent firstEvent = events.get(0);
81+
LoggingEvent secondEvent = events.get(1);
82+
LoggingEvent thirdEvent = events.get(2);
7383

74-
assertThat(events).hasSize(3);
75-
assertThat(events.get(0).getMessage()).isEqualTo("log message 1");
76-
assertThat(events.get(0).getMDC("trace_id")).isEqualTo(span1.getSpanContext().getTraceId());
77-
assertThat(events.get(0).getMDC("span_id")).isEqualTo(span1.getSpanContext().getSpanId());
78-
assertThat(events.get(0).getMDC("trace_flags"))
84+
assertThat(firstEvent.getMDC("trace_id")).isEqualTo(span1.getSpanContext().getTraceId());
85+
assertThat(firstEvent.getMDC("span_id")).isEqualTo(span1.getSpanContext().getSpanId());
86+
assertThat(firstEvent.getMDC("trace_flags"))
7987
.isEqualTo(span1.getSpanContext().getTraceFlags().asHex());
8088

81-
assertThat(events.get(1).getMessage()).isEqualTo("log message 2");
82-
assertThat(events.get(1).getMDC("trace_id")).isNull();
83-
assertThat(events.get(1).getMDC("span_id")).isNull();
84-
assertThat(events.get(1).getMDC("trace_flags")).isNull();
89+
assertThat(secondEvent.getMDC("trace_id")).isNull();
90+
assertThat(secondEvent.getMDC("span_id")).isNull();
91+
assertThat(secondEvent.getMDC("trace_flags")).isNull();
8592

86-
assertThat(events.get(2).getMessage()).isEqualTo("log message 3");
8793
// this explicit getMDCCopy() call here is to make sure that whole instrumentation is tested
88-
events.get(2).getMDCCopy();
89-
assertThat(events.get(2).getMDC("trace_id")).isEqualTo(span2.getSpanContext().getTraceId());
90-
assertThat(events.get(2).getMDC("span_id")).isEqualTo(span2.getSpanContext().getSpanId());
91-
assertThat(events.get(2).getMDC("trace_flags"))
94+
thirdEvent.getMDCCopy();
95+
assertThat(thirdEvent.getMDC("trace_id")).isEqualTo(span2.getSpanContext().getTraceId());
96+
assertThat(thirdEvent.getMDC("span_id")).isEqualTo(span2.getSpanContext().getSpanId());
97+
assertThat(thirdEvent.getMDC("trace_flags"))
9298
.isEqualTo(span2.getSpanContext().getTraceFlags().asHex());
9399
}
94100

@@ -97,13 +103,13 @@ void resourceAttributes() {
97103
logger.info("log message 1");
98104

99105
List<LoggingEvent> events = ListAppender.getEvents();
100-
101-
assertThat(events).hasSize(1);
102-
assertThat(events.get(0).getMessage()).isEqualTo("log message 1");
103-
assertThat(events.get(0).getMDC("trace_id")).isNull();
104-
assertThat(events.get(0).getMDC("span_id")).isNull();
105-
assertThat(events.get(0).getMDC("trace_flags")).isNull();
106-
assertThat(events.get(0).getMDC("service.name")).isEqualTo("unknown_service:java");
107-
assertThat(events.get(0).getMDC("telemetry.sdk.language")).isEqualTo("java");
106+
assertThat(events).extracting(LoggingEvent::getMessage).containsExactly("log message 1");
107+
108+
LoggingEvent event = events.get(0);
109+
assertThat(event.getMDC("trace_id")).isNull();
110+
assertThat(event.getMDC("span_id")).isNull();
111+
assertThat(event.getMDC("trace_flags")).isNull();
112+
assertThat(event.getMDC("service.name")).isEqualTo("unknown_service:java");
113+
assertThat(event.getMDC("telemetry.sdk.language")).isEqualTo("java");
108114
}
109115
}

0 commit comments

Comments
 (0)