From 89ca05bf3e20106908f815cef8f1cff7f725c0c8 Mon Sep 17 00:00:00 2001 From: Dave Syer Date: Thu, 15 Jan 2015 13:46:49 +0000 Subject: [PATCH] Remove printStackTrace() in test app --- .../cloud/netflix/turbine/amqp/AggregatorTest.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/spring-cloud-netflix-turbine-amqp/src/test/java/org/springframework/cloud/netflix/turbine/amqp/AggregatorTest.java b/spring-cloud-netflix-turbine-amqp/src/test/java/org/springframework/cloud/netflix/turbine/amqp/AggregatorTest.java index 6c2a63a8..48f9ef14 100644 --- a/spring-cloud-netflix-turbine-amqp/src/test/java/org/springframework/cloud/netflix/turbine/amqp/AggregatorTest.java +++ b/spring-cloud-netflix-turbine-amqp/src/test/java/org/springframework/cloud/netflix/turbine/amqp/AggregatorTest.java @@ -1,18 +1,22 @@ package org.springframework.cloud.netflix.turbine.amqp; +import static org.springframework.cloud.netflix.turbine.amqp.Aggregator.getPayloadData; + import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.util.Map; +import org.springframework.util.ReflectionUtils; + +import rx.Observable; +import rx.observables.GroupedObservable; + import com.netflix.turbine.aggregator.InstanceKey; import com.netflix.turbine.aggregator.StreamAggregator; import com.netflix.turbine.aggregator.TypeAndNameKey; import com.netflix.turbine.internal.JsonUtility; -import rx.Observable; -import rx.observables.GroupedObservable; -import static org.springframework.cloud.netflix.turbine.amqp.Aggregator.getPayloadData; public class AggregatorTest { @@ -41,7 +45,7 @@ public class AggregatorTest { sub.onNext(data); Thread.sleep(latencyBetweenEvents); } catch (Exception e) { - e.printStackTrace(); + ReflectionUtils.rethrowException(e); } } }