Update deprecated SSE annotation (#19)

lunatech-labs · Jun 15, 2024 · 9c02efa · 9c02efa
1 parent e56fc91
commit 9c02efa
Show file tree

Hide file tree

Showing 7 changed files with 15 additions and 15 deletions.
diff --git a/...3_Listen_and_Notify/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/...3_Listen_and_Notify/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java
@@ -7,7 +7,7 @@
 import io.vertx.mutiny.pgclient.PgPool;
 import io.vertx.mutiny.sqlclient.SqlConnection;
 import io.vertx.pgclient.PgNotification;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.inject.Inject;
 import jakarta.ws.rs.*;
@@ -22,7 +22,7 @@ public class ListenNotifyResource {
     @Path("{channel}")
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<JsonObject> listen(@PathParam("channel") String channel) {
         return client
                 .getConnection()

diff --git a/...4_Internal_Channels/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/...4_Internal_Channels/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java
@@ -7,7 +7,7 @@
 import io.vertx.mutiny.pgclient.PgPool;
 import io.vertx.mutiny.sqlclient.SqlConnection;
 import io.vertx.pgclient.PgNotification;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.inject.Inject;
 import jakarta.ws.rs.*;
@@ -22,7 +22,7 @@ public class ListenNotifyResource {
     @Path("{channel}")
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<JsonObject> listen(@PathParam("channel") String channel) {
         return client
                 .getConnection()

diff --git a/...4_Internal_Channels/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java b/...4_Internal_Channels/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java
@@ -2,7 +2,7 @@
 
 import io.smallrye.mutiny.Multi;
 import org.eclipse.microprofile.reactive.messaging.Channel;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.ws.rs.GET;
 import jakarta.ws.rs.Path;
@@ -17,7 +17,7 @@ public class PriceUpdatesResource {
 
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<PriceUpdate> prices() {
         return priceUpdates;
     }

diff --git a/...Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/...Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java
@@ -7,7 +7,7 @@
 import io.vertx.mutiny.pgclient.PgPool;
 import io.vertx.mutiny.sqlclient.SqlConnection;
 import io.vertx.pgclient.PgNotification;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.inject.Inject;
 import jakarta.ws.rs.*;
@@ -22,7 +22,7 @@ public class ListenNotifyResource {
     @Path("{channel}")
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<JsonObject> listen(@PathParam("channel") String channel) {
         return client
                 .getConnection()

diff --git a/...Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java b/...Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java
@@ -2,7 +2,7 @@
 
 import io.smallrye.mutiny.Multi;
 import org.eclipse.microprofile.reactive.messaging.Channel;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.ws.rs.GET;
 import jakarta.ws.rs.Path;
@@ -17,7 +17,7 @@ public class PriceUpdatesResource {
 
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<PriceUpdate> prices() {
         return priceUpdates;
     }

diff --git a/...nd_Stream_filtering/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/...nd_Stream_filtering/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java
@@ -7,7 +7,7 @@
 import io.vertx.mutiny.pgclient.PgPool;
 import io.vertx.mutiny.sqlclient.SqlConnection;
 import io.vertx.pgclient.PgNotification;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.inject.Inject;
 import jakarta.ws.rs.*;
@@ -22,7 +22,7 @@ public class ListenNotifyResource {
     @Path("{channel}")
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<JsonObject> listen(@PathParam("channel") String channel) {
         return client
                 .getConnection()

diff --git a/...nd_Stream_filtering/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java b/...nd_Stream_filtering/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java
@@ -2,7 +2,7 @@
 
 import io.smallrye.mutiny.Multi;
 import org.eclipse.microprofile.reactive.messaging.Channel;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 
 import jakarta.ws.rs.GET;
 import jakarta.ws.rs.Path;
@@ -18,14 +18,14 @@ public class PriceUpdatesResource {
 
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     public Multi<PriceUpdate> prices() {
         return priceUpdates;
     }
 
     @GET
     @Produces(MediaType.SERVER_SENT_EVENTS)
-    @RestSseElementType(MediaType.APPLICATION_JSON)
+    @RestStreamElementType(MediaType.APPLICATION_JSON)
     @Path("{id}")
     public Multi<PriceUpdate> pricesForProduct(@PathParam("id") Long id) {
         return priceUpdates.filter(priceUpdate -> priceUpdate.productId.equals(id));