diff --git a/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeBackendMain.java b/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeBackendMain.java index e3370fb3cd..17f6f519e3 100644 --- a/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeBackendMain.java +++ b/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeBackendMain.java @@ -46,6 +46,7 @@ public class FakeBackendMain { MessageMarshaller.builder() .register(ExportTraceServiceRequest.getDefaultInstance()) .register(ExportMetricsServiceRequest.getDefaultInstance()) + .register(ExportLogsServiceRequest.getDefaultInstance()) .build(); var mapper = JsonMapper.builder(); diff --git a/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeLogsCollectorService.java b/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeLogsCollectorService.java index ee550a61d4..591c3e78cb 100644 --- a/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeLogsCollectorService.java +++ b/smoke-tests/fake-backend/src/main/java/io/opentelemetry/smoketest/fakebackend/FakeLogsCollectorService.java @@ -11,7 +11,7 @@ import java.util.concurrent.LinkedBlockingDeque; public class FakeLogsCollectorService extends LogsServiceGrpc.LogsServiceImplBase{ - private BlockingQueue exportRequests = new LinkedBlockingDeque<>(); + private final BlockingQueue exportRequests = new LinkedBlockingDeque<>(); List getRequests() { return ImmutableList.copyOf(exportRequests);