(camel-quarkus) 33/41: Fixed pubnub

[jiriondrusek]

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

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

commit 34f4bb8821008af67357d5888ff14093d83fe770
Author: JiriOndrusek <ondrusek.j...@gmail.com>
AuthorDate: Tue Jun 18 10:51:39 2024 +0200

    Fixed pubnub
---
 .../quarkus/component/pubnub/deployment/PubnubProcessor.java  | 11 +++++++++--
 .../camel/quarkus/component/pubnub/it/PubnubResource.java     |  5 +++--
 2 files changed, 12 insertions(+), 4 deletions(-)

diff --git 
a/extensions/pubnub/deployment/src/main/java/org/apache/camel/quarkus/component/pubnub/deployment/PubnubProcessor.java
 
b/extensions/pubnub/deployment/src/main/java/org/apache/camel/quarkus/component/pubnub/deployment/PubnubProcessor.java
index 0d553fc155..208263fe70 100644
--- 
a/extensions/pubnub/deployment/src/main/java/org/apache/camel/quarkus/component/pubnub/deployment/PubnubProcessor.java
+++ 
b/extensions/pubnub/deployment/src/main/java/org/apache/camel/quarkus/component/pubnub/deployment/PubnubProcessor.java
@@ -50,7 +50,8 @@ class PubnubProcessor {
         String[] reflectiveClasses = index.getKnownClasses()
                 .stream()
                 .map(classInfo -> classInfo.name().toString())
-                .filter(name -> name.startsWith("com.pubnub.api.models"))
+                .filter(name -> name.startsWith("com.pubnub.internal.models")
+                        || name.startsWith("com.pubnub.internal.services"))
                 .toArray(String[]::new);
 
         return 
ReflectiveClassBuildItem.builder(reflectiveClasses).fields().build();
@@ -63,8 +64,14 @@ class PubnubProcessor {
         index.getKnownClasses()
                 .stream()
                 .map(classInfo -> classInfo.name().toString())
-                .filter(name -> name.startsWith("com.pubnub.api.services"))
+                .filter(name -> 
name.startsWith("com.pubnub.internal.services"))
                 .map(NativeImageProxyDefinitionBuildItem::new)
                 .forEach(proxyDefinitions::produce);
     }
+
+    @BuildStep
+    void addDependencies(BuildProducer<IndexDependencyBuildItem> 
indexDependency) {
+        indexDependency.produce(new IndexDependencyBuildItem("com.pubnub", 
"pubnub-core-impl"));
+    }
+
 }
diff --git 
a/integration-tests/pubnub/src/main/java/org/apache/camel/quarkus/component/pubnub/it/PubnubResource.java
 
b/integration-tests/pubnub/src/main/java/org/apache/camel/quarkus/component/pubnub/it/PubnubResource.java
index 26cba623e0..0fc78a3b5c 100644
--- 
a/integration-tests/pubnub/src/main/java/org/apache/camel/quarkus/component/pubnub/it/PubnubResource.java
+++ 
b/integration-tests/pubnub/src/main/java/org/apache/camel/quarkus/component/pubnub/it/PubnubResource.java
@@ -124,14 +124,15 @@ public class PubnubResource {
     public void setState() throws Exception {
         Map<String, String> state = new HashMap<>();
         state.put("test-state-key", "test-state-value");
-        
producerTemplate.requestBodyAndHeader("pubnub:test-state?pubNub=#pubNub", 
state, PubNubConstants.OPERATION, "SETSTATE");
+        
producerTemplate.requestBodyAndHeader("pubnub:test-state?uuid=myuuid&pubNub=#pubNub",
 state, PubNubConstants.OPERATION,
+                "SETSTATE");
     }
 
     @Path("/state")
     @GET
     @Produces(MediaType.TEXT_PLAIN)
     public String getState() throws Exception {
-        PNGetStateResult result = 
producerTemplate.requestBodyAndHeader("pubnub:test-state?pubNub=#pubNub", null,
+        PNGetStateResult result = 
producerTemplate.requestBodyAndHeader("pubnub:test-state?uuid=myuuid&pubNub=#pubNub",
 null,
                 PubNubConstants.OPERATION, "GETSTATE", PNGetStateResult.class);
         return 
result.getStateByUUID().get("test-state").getAsJsonObject().get("test-state-key").getAsString();
     }