Merge pull request #5361 from DicksengA/master

Missing methods in Quarkus Native

redisson-quarkus/redisson-quarkus-30/deployment/src/main/java/io/quarkus/redisson/client/deployment/QuarkusRedissonClientProcessor.java

@@ -28,6 +28,17 @@ import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
 import io.quarkus.deployment.builditem.nativeimage.RuntimeInitializedClassBuildItem;
 import io.quarkus.redisson.client.runtime.RedissonClientProducer;
 import io.quarkus.redisson.client.runtime.RedissonClientRecorder;
+import org.redisson.RedissonBucket;
+import org.redisson.RedissonMultimap;
+import org.redisson.RedissonObject;
+import org.redisson.api.RBucket;
+import org.redisson.api.RExpirable;
+import org.redisson.api.RObject;
+import org.redisson.api.RObjectReactive;
+import org.redisson.codec.Kryo5Codec;
+import org.redisson.config.*;
+import org.redisson.executor.RemoteExecutorService;
+import org.redisson.executor.RemoteExecutorServiceAsync;
 
 import java.io.IOException;
 
@@ -64,18 +75,52 @@ class QuarkusRedissonClientProcessor {
         nativeResources.produce(new NativeImageResourceBuildItem("META-INF/services/org.jboss.marshalling.ProviderDescriptor"));
         watchedFiles.produce(new HotDeploymentWatchedFileBuildItem("redisson.yaml"));
 
-        reflectiveItems.produce(new ReflectiveClassBuildItem(false, false, "org.redisson.codec.Kryo5Codec"));
+        reflectiveItems.produce(ReflectiveClassBuildItem.builder(Kryo5Codec.class)
+                .methods(false)
+                .fields(false)
+                .build()
+        );
+
+        reflectiveItems.produce(ReflectiveClassBuildItem.builder(
+                        RemoteExecutorService.class,
+                        RemoteExecutorServiceAsync.class)
+                .methods(true)
+                .fields(false)
+                .build()
+        );
+
+        reflectiveItems.produce(ReflectiveClassBuildItem.builder(
+                        Config.class,
+                        BaseConfig.class,
+                        BaseMasterSlaveServersConfig.class,
+                        SingleServerConfig.class,
+                        ReplicatedServersConfig.class,
+                        SentinelServersConfig.class,
+                        ClusterServersConfig.class)
+                .methods(true)
+                .fields(true)
+                .build()
+        );
+
+        reflectiveItems.produce(ReflectiveClassBuildItem.builder(
+                        RBucket.class,
+                        RedissonBucket.class,
+                        RedissonObject.class,
+                        RedissonMultimap.class)
+                .methods(true)
+                .fields(true)
+                .build()
+        );
+
+        reflectiveItems.produce(ReflectiveClassBuildItem.builder(
+                        RObjectReactive.class,
+                        RExpirable.class,
+                        RObject.class)
+                .methods(true)
+                .build()
+        );
 
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, false, "org.redisson.executor.RemoteExecutorService"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, false, "org.redisson.executor.RemoteExecutorServiceAsync"));
 
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.Config"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.BaseConfig"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.BaseMasterSlaveServersConfig"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.SingleServerConfig"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.ReplicatedServersConfig"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.SentinelServersConfig"));
-        reflectiveItems.produce(new ReflectiveClassBuildItem(true, true, "org.redisson.config.ClusterServersConfig"));
     }
 
     @BuildStep

redisson-quarkus/redisson-quarkus-30/integration-tests/src/main/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResource.java

@@ -31,11 +31,13 @@
 */
 package org.redisson.quarkus.client.it;
 
+import io.smallrye.mutiny.Uni;
 import jakarta.inject.Inject;
 import jakarta.ws.rs.GET;
 import jakarta.ws.rs.Path;
 import org.redisson.api.*;
 import org.redisson.api.redisnode.RedisNodes;
+import org.redisson.client.codec.StringCodec;
 
 import java.util.concurrent.ExecutionException;
 
@@ -81,4 +83,20 @@ public class QuarkusRedissonClientResource {
         return r.get();
     }
 
+    @GET
+    @Path("/bucket")
+    public Uni<String> getBucket(){
+        RBucketReactive<String> bucket = redisson.reactive().getBucket("test-bucket", new StringCodec());
+        return Uni.createFrom().future(bucket.set("world").toFuture())
+                .flatMap( unused -> Uni.createFrom().future(bucket.get().toFuture()));
+    }
+
+    @GET
+    @Path("/delBucket")
+    public Uni<Boolean> deleteBucket(){
+        RBucketReactive<String> bucket = redisson.reactive().getBucket("test-bucket", new StringCodec());
+        return Uni.createFrom().future(bucket.set("world").toFuture())
+                .flatMap( unused -> Uni.createFrom().future(bucket.delete().toFuture()));
+    }
+
 }

redisson-quarkus/redisson-quarkus-30/integration-tests/src/test/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResourceTest.java

@@ -38,6 +38,24 @@ public class QuarkusRedissonClientResourceTest {
                 .body(is("OK"));
     }
 
+    @Test
+    public void testBucket() {
+        given()
+                .when().get("/quarkus-redisson-client/bucket")
+                .then()
+                .statusCode(200)
+                .body(is("world"));
+    }
+
+    @Test
+    public void testDeleteBucket() {
+        given()
+                .when().get("/quarkus-redisson-client/delBucket")
+                .then()
+                .statusCode(200)
+                .body(is(true));
+    }
+
 //    @Test
 //    public void testExecuteTask() {
 //        given()