SRye Channel and Emitter leftovers

quarkusio · Apr 20, 2023 · 63d6a0a · 63d6a0a
1 parent 931a95e
commit 63d6a0a
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 10 deletions.
diff --git a/docs/src/main/asciidoc/kafka.adoc b/docs/src/main/asciidoc/kafka.adoc
@@ -177,7 +177,7 @@ Alternatively, your application can inject a `Multi` in your bean and subscribe
 [source, java]
 ----
 import io.smallrye.mutiny.Multi;
-import io.smallrye.reactive.messaging.annotations.Channel;
+import org.eclipse.microprofile.reactive.messaging.Channel;
 
 import jakarta.inject.Inject;
 import jakarta.ws.rs.GET;

diff --git a/docs/src/main/asciidoc/resteasy-reactive.adoc b/docs/src/main/asciidoc/resteasy-reactive.adoc
@@ -956,7 +956,7 @@ import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import io.smallrye.mutiny.Multi;
 
-import io.smallrye.reactive.messaging.annotations.Channel;
+import org.eclipse.microprofile.reactive.messaging.Channel;
 
 @Path("escoffier")
 public class Endpoint {
@@ -995,7 +995,7 @@ import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import io.smallrye.mutiny.Multi;
 
-import io.smallrye.reactive.messaging.annotations.Channel;
+import org.eclipse.microprofile.reactive.messaging.Channel;
 
 @Path("escoffier")
 public class Endpoint {

diff --git a/.../deployment/src/test/java/io/quarkus/smallrye/reactivemessaging/devmode/HttpFrontend.java b/.../deployment/src/test/java/io/quarkus/smallrye/reactivemessaging/devmode/HttpFrontend.java
@@ -5,11 +5,11 @@
 import jakarta.enterprise.inject.Instance;
 import jakarta.inject.Inject;
 
+import org.eclipse.microprofile.reactive.messaging.Channel;
 import org.reactivestreams.Publisher;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 
-import io.smallrye.reactive.messaging.annotations.Channel;
 import io.vertx.core.http.HttpServerResponse;
 import io.vertx.ext.web.Router;
 

diff --git a/...rc/test/java/io/quarkus/smallrye/reactivemessaging/signatures/ProcessorSignatureTest.java b/...rc/test/java/io/quarkus/smallrye/reactivemessaging/signatures/ProcessorSignatureTest.java
@@ -13,6 +13,8 @@
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 
+import org.eclipse.microprofile.reactive.messaging.Channel;
+import org.eclipse.microprofile.reactive.messaging.Emitter;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Message;
 import org.eclipse.microprofile.reactive.messaging.Outgoing;
@@ -26,8 +28,6 @@
 import org.reactivestreams.Publisher;
 
 import io.quarkus.test.QuarkusUnitTest;
-import io.smallrye.reactive.messaging.annotations.Channel;
-import io.smallrye.reactive.messaging.annotations.Emitter;
 
 @SuppressWarnings("unused")
 public class ProcessorSignatureTest {

diff --git a/...c/test/java/io/quarkus/smallrye/reactivemessaging/signatures/SubscriberSignatureTest.java b/...c/test/java/io/quarkus/smallrye/reactivemessaging/signatures/SubscriberSignatureTest.java
@@ -13,6 +13,8 @@
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 
+import org.eclipse.microprofile.reactive.messaging.Channel;
+import org.eclipse.microprofile.reactive.messaging.Emitter;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Message;
 import org.junit.jupiter.api.Test;
@@ -21,8 +23,6 @@
 import org.reactivestreams.Subscription;
 
 import io.quarkus.test.QuarkusUnitTest;
-import io.smallrye.reactive.messaging.annotations.Channel;
-import io.smallrye.reactive.messaging.annotations.Emitter;
 
 @SuppressWarnings("unused")
 public class SubscriberSignatureTest {

diff --git a/.../test/java/io/quarkus/smallrye/reactivemessaging/signatures/TransformerSignatureTest.java b/.../test/java/io/quarkus/smallrye/reactivemessaging/signatures/TransformerSignatureTest.java
@@ -12,6 +12,8 @@
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 
+import org.eclipse.microprofile.reactive.messaging.Channel;
+import org.eclipse.microprofile.reactive.messaging.Emitter;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Message;
 import org.eclipse.microprofile.reactive.messaging.Outgoing;
@@ -23,8 +25,6 @@
 import org.reactivestreams.Publisher;
 
 import io.quarkus.test.QuarkusUnitTest;
-import io.smallrye.reactive.messaging.annotations.Channel;
-import io.smallrye.reactive.messaging.annotations.Emitter;
 
 @SuppressWarnings("unused")
 public class TransformerSignatureTest {