Add support for InfinispanRemoteAggregationRepository

docs/modules/ROOT/pages/reference/extensions/infinispan.adoc

@@ -39,15 +39,14 @@ Or add the coordinates to your existing project:
 
 Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
 
-== Camel Quarkus limitations
-
-=== InfinispanRemoteAggregationRepository is unsupported
-
-At present the `InfinispanRemoteAggregationRepository` is not supported. The are some planned https://github.com/apache/camel-quarkus/issues/3657[future enhancements] to make this possible.
-
-
 == Additional Camel Quarkus configuration
 
+=== Infinispan Client Configuration
+
 You can either configure the Infinispan client via the relevant Camel Infinispan component & endpoint options, or you
 may use the https://quarkus.io/guides/infinispan-client#configuration-reference[Quarkus Infinispan extension configuration properties].
 
+=== Camel Infinispan `InfinispanRemoteAggregationRepository` in native mode
+
+If you chose to use the `InfinispanRemoteAggregationRepository` in native mode, then you must xref:extensions/core.adoc#quarkus.camel.native.reflection.serialization-enabled[enable native serialization support].
+

extensions/infinispan/runtime/pom.xml

@@ -51,12 +51,6 @@
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-infinispan</artifactId>
         </dependency>
-
-        <dependency>
-            <groupId>org.graalvm.nativeimage</groupId>
-            <artifactId>svm</artifactId>
-            <scope>provided</scope>
-        </dependency>
     </dependencies>
 
     <build>

extensions/infinispan/runtime/src/main/doc/configuration.adoc

@@ -1,2 +1,8 @@
+=== Infinispan Client Configuration
+
 You can either configure the Infinispan client via the relevant Camel Infinispan component & endpoint options, or you
 may use the https://quarkus.io/guides/infinispan-client#configuration-reference[Quarkus Infinispan extension configuration properties].
+
+=== Camel Infinispan `InfinispanRemoteAggregationRepository` in native mode
+
+If you chose to use the `InfinispanRemoteAggregationRepository` in native mode, then you must xref:extensions/core.adoc#quarkus.camel.native.reflection.serialization-enabled[enable native serialization support].

integration-tests/infinispan/src/main/java/org/apache/camel/quarkus/component/infinispan/InfinispanRoutes.java

@@ -166,20 +166,19 @@ public void configure() {
                 .autoStartup(false)
                 .to("mock:camelResultCreated");
 
-        // TODO: Reinstate aggregationRepository routes this https://github.com/apache/camel-quarkus/issues/3657
-        //from("direct:camelAggregation")
-        //        .aggregate(header(CORRELATOR_HEADER))
-        //        .aggregationRepository(createAggregationRepository("infinispan"))
-        //        .aggregationStrategy(createAggregationStrategy())
-        //        .completionSize(COMPLETION_SIZE)
-        //        .to("mock:camelAggregationResult");
-
-        //from("direct:quarkusAggregation")
-        //        .aggregate(header(CORRELATOR_HEADER))
-        //        .aggregationRepository(createAggregationRepository("infinispan-quarkus"))
-        //        .aggregationStrategy(createAggregationStrategy())
-        //        .completionSize(COMPLETION_SIZE)
-        //        .to("mock:quarkusAggregationResult");
+        from("direct:camelAggregation")
+                .aggregate(header(CORRELATOR_HEADER))
+                .aggregationRepository(createAggregationRepository("infinispan"))
+                .aggregationStrategy(createAggregationStrategy())
+                .completionSize(COMPLETION_SIZE)
+                .to("mock:camelAggregationResult");
+
+        from("direct:quarkusAggregation")
+                .aggregate(header(CORRELATOR_HEADER))
+                .aggregationRepository(createAggregationRepository("infinispan-quarkus"))
+                .aggregationStrategy(createAggregationStrategy())
+                .completionSize(COMPLETION_SIZE)
+                .to("mock:quarkusAggregationResult");
 
         from("direct:camelIdempotent")
                 .idempotentConsumer(header("MessageID"), createIdempotentRepository("infinispan"))
@@ -247,11 +246,9 @@ private InfinispanRemoteConfiguration getConfiguration(String componentName) {
         InfinispanRemoteComponent component = camelContext.getComponent(componentName, InfinispanRemoteComponent.class);
         InfinispanRemoteConfiguration configuration = component.getConfiguration().clone();
         configuration.setCacheContainerConfiguration(getConfigurationBuilder());
-        if (componentName.equals("infinispan-quarkus")) {
-            Set<RemoteCacheManager> beans = camelContext.getRegistry().findByType(RemoteCacheManager.class);
-            RemoteCacheManager cacheManager = beans.iterator().next();
-            configuration.setCacheContainer(cacheManager);
-        }
+        Set<RemoteCacheManager> beans = camelContext.getRegistry().findByType(RemoteCacheManager.class);
+        RemoteCacheManager cacheManager = beans.iterator().next();
+        configuration.setCacheContainer(cacheManager);
         return configuration;
     }
 

integration-tests/infinispan/src/main/resources/application.properties

@@ -15,3 +15,6 @@
 ## limitations under the License.
 ## ---------------------------------------------------------------------------
 quarkus.infinispan-client.devservices.enabled=false
+
+# Required by InfinispanRemoteAggregationRepository
+quarkus.camel.native.reflection.serialization-enabled=true

integration-tests/infinispan/src/test/java/org/apache/camel/quarkus/component/infinispan/InfinispanTest.java

@@ -22,7 +22,6 @@
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.RestAssured;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.Arguments;
@@ -52,7 +51,6 @@ public void afterEach() {
         }
     }
 
-    @Disabled("https://github.com/apache/camel-quarkus/issues/3657")
     @ParameterizedTest
     @MethodSource("componentNames")
     public void aggregate(String componentName) {