Register logs marshaller (#3392)
This commit is contained in:
parent
e6209c3b67
commit
1f3faca6b9
|
@ -46,6 +46,7 @@ public class FakeBackendMain {
|
|||
MessageMarshaller.builder()
|
||||
.register(ExportTraceServiceRequest.getDefaultInstance())
|
||||
.register(ExportMetricsServiceRequest.getDefaultInstance())
|
||||
.register(ExportLogsServiceRequest.getDefaultInstance())
|
||||
.build();
|
||||
|
||||
var mapper = JsonMapper.builder();
|
||||
|
|
|
@ -11,7 +11,7 @@ import java.util.concurrent.LinkedBlockingDeque;
|
|||
|
||||
public class FakeLogsCollectorService extends LogsServiceGrpc.LogsServiceImplBase{
|
||||
|
||||
private BlockingQueue<ExportLogsServiceRequest> exportRequests = new LinkedBlockingDeque<>();
|
||||
private final BlockingQueue<ExportLogsServiceRequest> exportRequests = new LinkedBlockingDeque<>();
|
||||
|
||||
List<ExportLogsServiceRequest> getRequests() {
|
||||
return ImmutableList.copyOf(exportRequests);
|
||||
|
|
Loading…
Reference in New Issue