Improved the quarkus example

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

Author: slinkydeveloper

examples/restful-ws-quarkus/src/main/java/io/cloudevents/examples/quarkus/client/UserEventsGenerator.java

@@ -1,28 +1,33 @@
 package io.cloudevents.examples.quarkus.client;
 
-import java.net.URI;
-import java.time.Duration;
-import java.util.UUID;
-import javax.enterprise.context.ApplicationScoped;
-import javax.enterprise.event.Observes;
-import javax.inject.Inject;
-import javax.ws.rs.core.MediaType;
-
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.cloudevents.CloudEvent;
+import io.cloudevents.CloudEventData;
 import io.cloudevents.core.builder.CloudEventBuilder;
+import io.cloudevents.core.data.PojoCloudEventData;
 import io.cloudevents.examples.quarkus.model.User;
 import io.quarkus.runtime.StartupEvent;
 import io.smallrye.mutiny.Multi;
-import io.vertx.core.json.Json;
 import org.eclipse.microprofile.rest.client.inject.RestClient;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.enterprise.context.ApplicationScoped;
+import javax.enterprise.event.Observes;
+import javax.inject.Inject;
+import javax.ws.rs.core.MediaType;
+import java.net.URI;
+import java.time.Duration;
+import java.util.UUID;
+
 @ApplicationScoped
 public class UserEventsGenerator {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(UserEventsGenerator.class);
 
+    @Inject
+    ObjectMapper mapper;
+
     @Inject
     @RestClient
     UserClient userClient;
@@ -44,16 +49,16 @@ private CloudEvent createEvent(long id) {
             .withType("io.cloudevents.examples.quarkus.user")
             .withId(UUID.randomUUID().toString())
             .withDataContentType(MediaType.APPLICATION_JSON)
-            .withData(createUserAsByteArray(id))
+            .withData(createUser(id))
             .build();
     }
 
-    private byte[] createUserAsByteArray(Long id) {
+    private CloudEventData createUser(Long id) {
         User user = new User()
             .setAge(id.intValue())
             .setUsername("user" + id)
             .setFirstName("firstName" + id)
             .setLastName("lastName" + id);
-        return Json.encode(user).getBytes();
+        return PojoCloudEventData.wrap(user, mapper::writeValueAsBytes);
     }
 }

examples/restful-ws-quarkus/src/main/java/io/cloudevents/examples/quarkus/resources/UserResource.java

@@ -1,12 +1,13 @@
 package io.cloudevents.examples.quarkus.resources;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.cloudevents.CloudEvent;
 import io.cloudevents.examples.quarkus.model.User;
-import io.vertx.core.buffer.Buffer;
-import io.vertx.core.json.Json;
+import io.cloudevents.jackson.PojoCloudEventDataMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.inject.Inject;
 import javax.ws.rs.*;
 import javax.ws.rs.core.Context;
 import javax.ws.rs.core.MediaType;
@@ -22,6 +23,9 @@ public class UserResource {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(UserResource.class);
 
+    @Inject
+    ObjectMapper mapper;
+
     @Context
     UriInfo uriInfo;
 
@@ -46,7 +50,10 @@ public Response create(CloudEvent event) {
         if (event == null || event.getData() == null) {
             throw new BadRequestException("Invalid data received. Null or empty event");
         }
-        User user = Json.decodeValue(Buffer.buffer(event.getData().toBytes()), User.class);
+        User user = PojoCloudEventDataMapper
+            .from(mapper, User.class)
+            .map(event.getData())
+            .getValue();
         if (users.containsKey(user.getUsername())) {
             throw new BadRequestException("Username already exists: " + user.getUsername());
         }