feat: solution for step 5

Author: loicmathieu

bookmark-service/pom.xml

@@ -51,10 +51,10 @@
       <artifactId>quarkus-smallrye-metrics</artifactId>
     </dependency>
     <!-- Step 5 dependencies -->
-<!--    <dependency>-->
-<!--      <groupId>io.quarkus</groupId>-->
-<!--      <artifactId>quarkus-smallrye-reactive-messaging-amqp</artifactId>-->
-<!--    </dependency>-->
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-smallrye-reactive-messaging-amqp</artifactId>
+    </dependency>
     <!--/ Step 5 dependencies -->
     <!-- Step 6 dependencies -->
 <!--    <dependency>-->

bookmark-service/src/main/java/fr/loicmathieu/bookmarkit/BookmarkResource.java

@@ -1,5 +1,7 @@
 package fr.loicmathieu.bookmarkit;
 
+import io.smallrye.reactive.messaging.annotations.Emitter;
+import io.smallrye.reactive.messaging.annotations.Stream;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 import org.eclipse.microprofile.metrics.annotation.Counted;
 import org.eclipse.microprofile.metrics.annotation.Timed;
@@ -8,6 +10,7 @@
 import org.slf4j.LoggerFactory;
 
 import javax.annotation.PostConstruct;
+import javax.inject.Inject;
 import javax.transaction.Transactional;
 import javax.ws.rs.Consumes;
 import javax.ws.rs.DELETE;
@@ -25,11 +28,11 @@
 @Produces(MediaType.APPLICATION_JSON)
 @Consumes(MediaType.APPLICATION_JSON)
 public class BookmarkResource {
+    @ConfigProperty(name="greeting") String greeting;
 
-    private static final Logger LOGGER = LoggerFactory.getLogger(BookmarkResource.class);
+    @Inject @Stream("bookmarks") Emitter<Bookmark> emitter;
 
-    @ConfigProperty(name = "greeting")
-    private String greeting;
+    private static final Logger LOGGER = LoggerFactory.getLogger(BookmarkResource.class);
 
     @PostConstruct
     void init() {
@@ -61,11 +64,12 @@ public Bookmark getBookmark(@PathParam("id") Long id) {
     @Timed(name = "createBookmark.time")
     public Response createBookmark(Bookmark bookmark) {
         bookmark.persist();
+        emitter.send(bookmark);
         return Response.status(Response.Status.CREATED).entity(bookmark).build();
     }
 
     @PUT
-    @Path("/{id}")
+    @Path("{id}")
     @Transactional
     @Operation(summary = "Update a bookmark")
     @Counted(name = "updateBookmark.count")
@@ -79,7 +83,7 @@ public void updateBookmark(Bookmark bookmark, @PathParam("id") Long id) {
     }
 
     @DELETE
-    @Path("/{id}")
+    @Path("{id}")
     @Transactional
     @Operation(summary = "Delete a bookmark")
     @Counted(name = "deleteBookmark.count")

bookmark-service/src/main/resources/application.properties

@@ -8,4 +8,12 @@ quarkus.hibernate-orm.database.generation=drop-and-create
 quarkus.hibernate-orm.sql-load-script=import.sql
 
 greeting=World
-%dev.greeting=Dev
+%dev.greeting=Dev
+
+# Configures the AMQP broker credentials.
+amqp-username=quarkus
+amqp-password=quarkus
+# Configure the AMQP connector to write to the `bookmark` address
+mp.messaging.outgoing.bookmarks.connector=smallrye-amqp
+mp.messaging.outgoing.bookmarks.address=bookmarks
+mp.messaging.outgoing.bookmarks.durable=true