[camel] branch main updated: CAMEL-17934: Provide a ClassLoder to CqlSessionBuilder if available

[ja...@apache.org]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new d996d972253 CAMEL-17934: Provide a ClassLoder to CqlSessionBuilder if available
d996d972253 is described below

commit d996d972253de2949f6cedd2b1f8998472373f9e
Author: James Netherton <ja...@gmail.com>
AuthorDate: Fri Apr 8 13:16:22 2022 +0100

    CAMEL-17934: Provide a ClassLoder to CqlSessionBuilder if available
---
 .../org/apache/camel/component/cassandra/CassandraEndpoint.java     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
index 1bd2ca504b4..2c1f8d5d565 100644
--- a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
+++ b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java
@@ -153,6 +153,12 @@ public class CassandraEndpoint extends ScheduledPollEndpoint {
 
         sessionBuilder.withLocalDatacenter(datacenter);
         sessionBuilder.withKeyspace(keyspace);
+
+        ClassLoader classLoader = getCamelContext().getApplicationContextClassLoader();
+        if (classLoader != null) {
+            sessionBuilder.withClassLoader(classLoader);
+        }
+
         return sessionBuilder;
     }