Example with protostream marshalling fixed

Author: karesti

sample/src/main/java/io/quarkiverse/infinispan/embedded/sample/Greeting.java

@@ -1,4 +1,12 @@
 package io.quarkiverse.infinispan.embedded.sample;
 
+import org.infinispan.protostream.GeneratedSchema;
+import org.infinispan.protostream.annotations.Proto;
+import org.infinispan.protostream.annotations.ProtoSchema;
+
+@Proto
 public record Greeting(String name, String message) {
+    @ProtoSchema(includeClasses = { Greeting.class })
+    public interface GameSchema extends GeneratedSchema {
+    }
 }

sample/src/main/java/io/quarkiverse/infinispan/embedded/sample/InfinispanGreetingResource.java

@@ -9,9 +9,11 @@
 
 import org.infinispan.Cache;
 import org.infinispan.commons.api.CacheContainerAdmin;
+import org.infinispan.commons.dataconversion.MediaType;
 import org.infinispan.configuration.cache.CacheMode;
 import org.infinispan.configuration.cache.Configuration;
 import org.infinispan.configuration.cache.ConfigurationBuilder;
+import org.infinispan.health.ClusterHealth;
 import org.infinispan.manager.EmbeddedCacheManager;
 
 import io.quarkus.logging.Log;
@@ -28,13 +30,19 @@ public class InfinispanGreetingResource {
     @Startup
     void init() {
         Configuration config = new ConfigurationBuilder()
+                .encoding().mediaType(MediaType.APPLICATION_PROTOSTREAM)
                 .clustering().cacheMode(CacheMode.DIST_ASYNC).build();
         Log.info("Create mycache with config " + config);
         cacheManager.administration()
                 .withFlags(CacheContainerAdmin.AdminFlag.VOLATILE)
                 .getOrCreateCache(CACHE_NAME, config);
     }
 
+    @GET
+    public ClusterHealth clusterHealth() {
+        return cacheManager.getHealth().getClusterHealth();
+    }
+
     @POST
     @Path("/{id}")
     public CompletionStage<String> postGreeting(String id, Greeting greeting) {