This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new 8a7d25c Fixed CS for camel-reactive-streams 8a7d25c is described below commit 8a7d25c543262ad6820b79bd636bd4d0490464f8 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Jan 23 10:20:04 2019 +0100 Fixed CS for camel-reactive-streams --- .../camel/component/reactive/streams/ReactiveStreamsComponent.java | 2 +- .../camel/component/reactive/streams/ReactiveStreamsEndpoint.java | 2 +- .../apache/camel/component/reactive/streams/ReactiveStreamsHelper.java | 2 +- .../camel/component/reactive/streams/util/UnwrapStreamProcessor.java | 2 +- .../reactive/streams/BackpressurePublisherRoutePolicyTest.java | 2 +- .../component/reactive/streams/tck/CamelSubscriberVerificationTest.java | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java index 7b57374..3041108 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java @@ -22,9 +22,9 @@ import org.apache.camel.Endpoint; import org.apache.camel.RuntimeCamelException; import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService; import org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration; +import org.apache.camel.spi.Metadata; import org.apache.camel.spi.annotations.Component; import org.apache.camel.support.DefaultComponent; -import org.apache.camel.spi.Metadata; import org.apache.camel.support.service.ServiceHelper; /** diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java index 51b53d2..17b3d08 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java @@ -22,10 +22,10 @@ import org.apache.camel.Producer; import org.apache.camel.api.management.ManagedAttribute; import org.apache.camel.api.management.ManagedResource; import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService; -import org.apache.camel.support.DefaultEndpoint; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; import org.apache.camel.spi.UriPath; +import org.apache.camel.support.DefaultEndpoint; /** * Reactive Camel using reactive streams diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsHelper.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsHelper.java index 810f85c..e0c9624 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsHelper.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsHelper.java @@ -23,9 +23,9 @@ import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsServi import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsServiceFactory; import org.apache.camel.component.reactive.streams.api.DispatchCallback; import org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration; -import org.apache.camel.support.DefaultExchange; import org.apache.camel.spi.FactoryFinder; import org.apache.camel.support.CamelContextHelper; +import org.apache.camel.support.DefaultExchange; import org.apache.camel.util.ObjectHelper; public final class ReactiveStreamsHelper { diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/util/UnwrapStreamProcessor.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/util/UnwrapStreamProcessor.java index ddf39da..77d7fd3 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/util/UnwrapStreamProcessor.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/util/UnwrapStreamProcessor.java @@ -21,8 +21,8 @@ import java.util.List; import org.apache.camel.AsyncCallback; import org.apache.camel.Exchange; -import org.apache.camel.support.AsyncProcessorSupport; import org.apache.camel.support.AsyncProcessorHelper; +import org.apache.camel.support.AsyncProcessorSupport; import org.reactivestreams.Publisher; import org.reactivestreams.Subscriber; import org.reactivestreams.Subscription; diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressurePublisherRoutePolicyTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressurePublisherRoutePolicyTest.java index 2e95e92..0a1ec7b 100644 --- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressurePublisherRoutePolicyTest.java +++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressurePublisherRoutePolicyTest.java @@ -26,8 +26,8 @@ import org.apache.camel.StatefulService; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.reactive.streams.api.CamelReactiveStreams; import org.apache.camel.component.reactive.streams.support.TestSubscriber; -import org.apache.camel.throttling.ThrottlingInflightRoutePolicy; import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.throttling.ThrottlingInflightRoutePolicy; import org.junit.Test; import org.reactivestreams.Publisher; diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/tck/CamelSubscriberVerificationTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/tck/CamelSubscriberVerificationTest.java index 53b2477..64854c0 100644 --- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/tck/CamelSubscriberVerificationTest.java +++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/tck/CamelSubscriberVerificationTest.java @@ -21,8 +21,8 @@ import org.apache.camel.Exchange; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.reactive.streams.api.CamelReactiveStreams; import org.apache.camel.impl.DefaultCamelContext; -import org.apache.camel.support.DefaultExchange; import org.apache.camel.impl.DefaultShutdownStrategy; +import org.apache.camel.support.DefaultExchange; import org.reactivestreams.Subscriber; import org.reactivestreams.tck.SubscriberBlackboxVerification; import org.reactivestreams.tck.TestEnvironment;