[camel-quarkus] branch 2.7.x updated: camel-quarkus-paho: Add reflection config for RandomAccessFile (#3691) (#3700)

[zhfeng]

This is an automated email from the ASF dual-hosted git repository.

zhfeng pushed a commit to branch 2.7.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/2.7.x by this push:
     new b6b5ee9b21 camel-quarkus-paho: Add reflection config for 
RandomAccessFile (#3691) (#3700)
b6b5ee9b21 is described below

commit b6b5ee9b219028157f1aee651ad53b92737bac08
Author: Amos Feng <zh.f...@gmail.com>
AuthorDate: Wed Apr 6 12:15:27 2022 +0800

    camel-quarkus-paho: Add reflection config for RandomAccessFile (#3691) 
(#3700)
---
 .../apache/camel/quarkus/component/paho/deployment/PahoProcessor.java | 2 ++
 .../java/org/apache/camel/quarkus/component/paho/PahoResource.java    | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
 
b/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
index 5858d6608f..4a71c2df67 100644
--- 
a/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
+++ 
b/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.quarkus.component.paho.deployment;
 
+import java.io.RandomAccessFile;
 import java.nio.channels.FileChannel;
 import java.nio.channels.FileLock;
 import java.util.ResourceBundle;
@@ -45,6 +46,7 @@ class PahoProcessor {
         p.produce(new ReflectiveClassBuildItem(false, false, 
ResourceBundle.class));
         p.produce(new ReflectiveClassBuildItem(false, false, FileLock.class));
         p.produce(new ReflectiveClassBuildItem(true, false, 
FileChannel.class));
+        p.produce(new ReflectiveClassBuildItem(true, false, 
RandomAccessFile.class));
         p.produce(new ReflectiveClassBuildItem(true, false, 
"sun.nio.ch.FileLockImpl"));
     }
 
diff --git 
a/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/PahoResource.java
 
b/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/PahoResource.java
index e5e84099d0..68282cb497 100644
--- 
a/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/PahoResource.java
+++ 
b/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/PahoResource.java
@@ -92,7 +92,7 @@ public class PahoResource {
     @GET
     @Produces(MediaType.TEXT_PLAIN)
     public String 
readThenWriteWithFilePersistenceShouldSucceed(@QueryParam("message") String 
message) throws Exception {
-        
producerTemplate.requestBody("paho:withFilePersistence?retained=true&cleanSession=false&persistence=FILE",
 message);
-        return 
consumerTemplate.receiveBody("paho:withFilePersistence?cleanSession=false&persistence=FILE",
 5000, String.class);
+        
producerTemplate.requestBody("paho:withFilePersistence?retained=true&persistence=FILE",
 message);
+        return 
consumerTemplate.receiveBody("paho:withFilePersistence?persistence=FILE", 5000, 
String.class);
     }
 }