Bounding the queue for StreamSpanReporter

without this change the limit is MAX_INTEGER. With this change we set it to 1000

fixes #378
This commit is contained in:
Marcin Grzejszczak
2016-08-18 12:20:01 +02:00
parent fdea5d6bac
commit ef1cd65f0c

View File

@@ -45,7 +45,7 @@ public class StreamSpanReporter implements SpanReporter {
*/
public static final String POLLER = "streamSpanReporterPoller";
private BlockingQueue<Span> queue = new LinkedBlockingQueue<>();
private BlockingQueue<Span> queue = new LinkedBlockingQueue<>(1000);
private final HostLocator endpointLocator;
private final SpanMetricReporter spanMetricReporter;