Commit 89ca05bf by Dave Syer

Remove printStackTrace() in test app

parent 17484fad
package org.springframework.cloud.netflix.turbine.amqp; package org.springframework.cloud.netflix.turbine.amqp;
import static org.springframework.cloud.netflix.turbine.amqp.Aggregator.getPayloadData;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.InputStream; import java.io.InputStream;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.util.Map; 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.InstanceKey;
import com.netflix.turbine.aggregator.StreamAggregator; import com.netflix.turbine.aggregator.StreamAggregator;
import com.netflix.turbine.aggregator.TypeAndNameKey; import com.netflix.turbine.aggregator.TypeAndNameKey;
import com.netflix.turbine.internal.JsonUtility; 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 { public class AggregatorTest {
...@@ -41,7 +45,7 @@ public class AggregatorTest { ...@@ -41,7 +45,7 @@ public class AggregatorTest {
sub.onNext(data); sub.onNext(data);
Thread.sleep(latencyBetweenEvents); Thread.sleep(latencyBetweenEvents);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); ReflectionUtils.rethrowException(e);
} }
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment