This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-3.14.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit edc1195dbeea238c6eaf690e5b31a1a433632e57 Author: James Netherton <[email protected]> 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 7e25c2acf6b..2789e3c4c84 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; }
