diff --git a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHook.java b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHook.java index f164de280..34816b95e 100644 --- a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHook.java +++ b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHook.java @@ -5,13 +5,11 @@ import org.apache.commons.logging.LogFactory; import org.springframework.cloud.sleuth.Span; import org.springframework.cloud.sleuth.TraceKeys; import org.springframework.cloud.sleuth.Tracer; - import rx.functions.Action0; import rx.plugins.RxJavaErrorHandler; import rx.plugins.RxJavaObservableExecutionHook; import rx.plugins.RxJavaPlugins; import rx.plugins.RxJavaSchedulersHook; -import rx.plugins.SleuthRxJavaPlugins; /** * {@link RxJavaSchedulersHook} that wraps an {@link Action0} into its tracing @@ -41,7 +39,7 @@ class SleuthRxJavaSchedulersHook extends RxJavaSchedulersHook { RxJavaObservableExecutionHook observableExecutionHook = RxJavaPlugins.getInstance().getObservableExecutionHook(); logCurrentStateOfRxJavaPlugins(errorHandler, observableExecutionHook); - SleuthRxJavaPlugins.resetPlugins(); + RxJavaPlugins.getInstance().reset(); RxJavaPlugins.getInstance().registerSchedulersHook(this); RxJavaPlugins.getInstance().registerErrorHandler(errorHandler); RxJavaPlugins.getInstance().registerObservableExecutionHook(observableExecutionHook); diff --git a/spring-cloud-sleuth-core/src/main/java/rx/plugins/SleuthRxJavaPlugins.java b/spring-cloud-sleuth-core/src/main/java/rx/plugins/SleuthRxJavaPlugins.java deleted file mode 100644 index 0e746eb04..000000000 --- a/spring-cloud-sleuth-core/src/main/java/rx/plugins/SleuthRxJavaPlugins.java +++ /dev/null @@ -1,19 +0,0 @@ -package rx.plugins; - -/** - * {@link RxJavaPlugins} helper class to access the package scope method of - * {@link RxJavaPlugins#reset()}. - * - * @deprecated Will disappear once this gets closed - * https://github.com/ReactiveX/RxJava/issues/2297 - * - * @author Shivang Shah - */ -@Deprecated -public class SleuthRxJavaPlugins { - - public static void resetPlugins() { - RxJavaPlugins.getInstance().reset(); - } - -} diff --git a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHookTests.java b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHookTests.java index 4d30ba702..17f1c482f 100644 --- a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHookTests.java +++ b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaSchedulersHookTests.java @@ -16,7 +16,6 @@ import rx.plugins.RxJavaErrorHandler; import rx.plugins.RxJavaObservableExecutionHook; import rx.plugins.RxJavaPlugins; import rx.plugins.RxJavaSchedulersHook; -import rx.plugins.SleuthRxJavaPlugins; /** * @@ -34,7 +33,7 @@ public class SleuthRxJavaSchedulersHookTests { @Before @After public void setup() { - SleuthRxJavaPlugins.resetPlugins(); + RxJavaPlugins.getInstance().reset(); caller = new StringBuilder(); } diff --git a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaTests.java b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaTests.java index 4c1215d90..d4326f59d 100644 --- a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaTests.java +++ b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/rxjava/SleuthRxJavaTests.java @@ -25,11 +25,11 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import rx.Observable; import rx.functions.Action0; -import rx.plugins.SleuthRxJavaPlugins; import rx.schedulers.Schedulers; import static com.jayway.awaitility.Awaitility.await; import static org.springframework.cloud.sleuth.assertions.SleuthAssertions.then; +import rx.plugins.RxJavaPlugins; @RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = {SleuthRxJavaTests.TestConfig.class}) @@ -53,7 +53,7 @@ public class SleuthRxJavaTests { @BeforeClass @AfterClass public static void cleanUp() { - SleuthRxJavaPlugins.resetPlugins(); + RxJavaPlugins.getInstance().reset(); } @Test