From ef1cd65f0c6594941c5446f04b0422fe89772ce6 Mon Sep 17 00:00:00 2001
From: Marcin Grzejszczak <marcin@grzejszczak.pl>
Date: Thu, 18 Aug 2016 12:20:01 +0200
Subject: [PATCH] Bounding the queue for StreamSpanReporter

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

fixes #378
---
 .../springframework/cloud/sleuth/stream/StreamSpanReporter.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java b/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java
index 7ecbd8c9a..575f06515 100644
--- a/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java
+++ b/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java
@@ -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;