Skip to content

Commit 2a61aa1

Browse files
committed
fix
1 parent 90f4ece commit 2a61aa1

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/init/AzureMonitorLogFilteringProcessor.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import io.opentelemetry.api.trace.SpanContext;
1313
import io.opentelemetry.context.Context;
1414
import io.opentelemetry.instrumentation.api.instrumenter.LocalRootSpan;
15+
import io.opentelemetry.sdk.common.CompletableResultCode;
1516
import io.opentelemetry.sdk.internal.AttributesMap;
1617
import io.opentelemetry.sdk.logs.LogRecordProcessor;
1718
import io.opentelemetry.sdk.logs.ReadWriteLogRecord;
@@ -117,6 +118,18 @@ public void onEmit(Context context, ReadWriteLogRecord logRecord) {
117118
batchLogRecordProcessor.onEmit(context, logRecord);
118119
}
119120

121+
public CompletableResultCode shutdown() {
122+
return batchLogRecordProcessor.shutdown();
123+
}
124+
125+
public CompletableResultCode forceFlush() {
126+
return batchLogRecordProcessor.forceFlush();
127+
}
128+
129+
public void close() {
130+
batchLogRecordProcessor.close();
131+
}
132+
120133
@Nullable
121134
private static Class<?> getSdkReadWriteLogRecordClass() {
122135
try {

0 commit comments

Comments
 (0)