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,11 +1,15 @@
 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;
 import org.eclipse.microprofile.openapi.annotations.Operation;
+import org.eclipse.microprofile.reactive.messaging.Outgoing;
 
 import javax.annotation.PostConstruct;
+import javax.inject.Inject;
 import javax.transaction.Transactional;
 import javax.ws.rs.Consumes;
 import javax.ws.rs.DELETE;
@@ -26,6 +30,8 @@
 public class BookmarkResource {
     @ConfigProperty(name="greeting") String greeting;
 
+    @Inject @Stream("bookmarks") Emitter<Bookmark> emitter;
+
     @PostConstruct
     void init(){
         System.out.println("Hello " + greeting);
@@ -55,6 +61,7 @@ public Bookmark get(@PathParam("id") Long id) {
     @Timed(name="create.time")
     public Response create(Bookmark bookmark){
         bookmark.persist();
+        emitter.send(bookmark);
         return Response.created(URI.create("/bookmarks/" + bookmark.id)).build();
     }
 

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

@@ -8,4 +8,12 @@ quarkus.datasource.password = connor
 quarkus.hibernate-orm.database.generation=drop-and-create
 
 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