From 9c02efadeb94679fd8123973ee4d57b9135b4cd0 Mon Sep 17 00:00:00 2001 From: "Neil J. L. Benn" Date: Sat, 15 Jun 2024 11:38:44 +0200 Subject: [PATCH] Update deprecated SSE annotation (#19) --- .../com/lunatech/training/quarkus/ListenNotifyResource.java | 4 ++-- .../com/lunatech/training/quarkus/ListenNotifyResource.java | 4 ++-- .../com/lunatech/training/quarkus/PriceUpdatesResource.java | 4 ++-- .../com/lunatech/training/quarkus/ListenNotifyResource.java | 4 ++-- .../com/lunatech/training/quarkus/PriceUpdatesResource.java | 4 ++-- .../com/lunatech/training/quarkus/ListenNotifyResource.java | 4 ++-- .../com/lunatech/training/quarkus/PriceUpdatesResource.java | 6 +++--- 7 files changed, 15 insertions(+), 15 deletions(-) diff --git a/code/exercise_013_Listen_and_Notify/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/code/exercise_013_Listen_and_Notify/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java index faa66cf..394b09f 100644 --- a/code/exercise_013_Listen_and_Notify/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java +++ b/code/exercise_013_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 listen(@PathParam("channel") String channel) { return client .getConnection() diff --git a/code/exercise_014_Internal_Channels/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/code/exercise_014_Internal_Channels/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java index faa66cf..394b09f 100644 --- a/code/exercise_014_Internal_Channels/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java +++ b/code/exercise_014_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 listen(@PathParam("channel") String channel) { return client .getConnection() diff --git a/code/exercise_014_Internal_Channels/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java b/code/exercise_014_Internal_Channels/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java index d830758..669d4a7 100644 --- a/code/exercise_014_Internal_Channels/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java +++ b/code/exercise_014_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 prices() { return priceUpdates; } diff --git a/code/exercise_015_Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/code/exercise_015_Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java index faa66cf..394b09f 100644 --- a/code/exercise_015_Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java +++ b/code/exercise_015_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 listen(@PathParam("channel") String channel) { return client .getConnection() diff --git a/code/exercise_015_Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java b/code/exercise_015_Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java index 9afee04..6a5e79c 100644 --- a/code/exercise_015_Connecting_to_Kafka/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java +++ b/code/exercise_015_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 prices() { return priceUpdates; } diff --git a/code/exercise_016_Dead_Letter_Queue_and_Stream_filtering/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java b/code/exercise_016_Dead_Letter_Queue_and_Stream_filtering/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java index faa66cf..394b09f 100644 --- a/code/exercise_016_Dead_Letter_Queue_and_Stream_filtering/src/main/java/com/lunatech/training/quarkus/ListenNotifyResource.java +++ b/code/exercise_016_Dead_Letter_Queue_and_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 listen(@PathParam("channel") String channel) { return client .getConnection() diff --git a/code/exercise_016_Dead_Letter_Queue_and_Stream_filtering/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java b/code/exercise_016_Dead_Letter_Queue_and_Stream_filtering/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java index a4ba467..26f7d82 100644 --- a/code/exercise_016_Dead_Letter_Queue_and_Stream_filtering/src/main/java/com/lunatech/training/quarkus/PriceUpdatesResource.java +++ b/code/exercise_016_Dead_Letter_Queue_and_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 prices() { return priceUpdates; } @GET @Produces(MediaType.SERVER_SENT_EVENTS) - @RestSseElementType(MediaType.APPLICATION_JSON) + @RestStreamElementType(MediaType.APPLICATION_JSON) @Path("{id}") public Multi pricesForProduct(@PathParam("id") Long id) { return priceUpdates.filter(priceUpdate -> priceUpdate.productId.equals(id));