Skip to content
This repository was archived by the owner on Jul 1, 2022. It is now read-only.

Commit f726853

Browse files
authored
Improve RemoteReporter code coverage (#380) (#692)
Signed-off-by: adnan <[email protected]>
1 parent 5e81d89 commit f726853

File tree

2 files changed

+26
-1
lines changed

2 files changed

+26
-1
lines changed

jaeger-core/src/test/java/io/jaegertracing/internal/reporters/RemoteReporterTest.java

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -368,6 +368,31 @@ public int append(JaegerSpan span) {
368368
assertEquals(0, metricsFactory.getCounter("jaeger_tracer_reporter_spans", "result=dropped"));
369369
}
370370

371+
@Test
372+
public void testUpdateErrorMetricWhenCommandExecuteFails() throws Exception {
373+
374+
int reporterFailures = 5;
375+
376+
sender = new InMemorySender() {
377+
@Override
378+
public int append(JaegerSpan span) throws SenderException {
379+
throw new SenderException("", reporterFailures);
380+
}
381+
};
382+
383+
RemoteReporter reporter = new Builder()
384+
.withSender(sender)
385+
.withFlushInterval(flushInterval)
386+
.withMaxQueueSize(maxQueueSize)
387+
.withMetrics(metrics)
388+
.build();
389+
390+
reporter.report(newSpan());
391+
reporter.close();
392+
393+
assertEquals(reporterFailures, metricsFactory.getCounter("jaeger_tracer_reporter_spans", "result=err"));
394+
}
395+
371396
private JaegerSpan newSpan() {
372397
return tracer.buildSpan("x").start();
373398
}

jaeger-core/src/test/java/io/jaegertracing/internal/senders/InMemorySender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public List<JaegerSpan> getReceived() {
5151
}
5252

5353
@Override
54-
public int append(JaegerSpan span) {
54+
public int append(JaegerSpan span) throws SenderException {
5555
try {
5656
semaphore.acquire();
5757
} catch (InterruptedException e) {

0 commit comments

Comments
 (0)