This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit d9c22030c622c4b8b0234381e285bd044ea61e90 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu Feb 2 14:20:52 2023 +0100 CAMEL-18996 - Camel-CassandraQL: Adding a parameter to pass a list of ExtraTypesCodec to SessionBuilder Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../java/org/apache/camel/component/cassandra/CassandraEndpoint.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 82fd51dccae..c4a4d146dd7 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 @@ -43,8 +43,8 @@ import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; import org.apache.camel.spi.UriPath; import org.apache.camel.support.CamelContextHelper; -import org.apache.camel.support.ObjectHelper; import org.apache.camel.support.ScheduledPollEndpoint; +import org.apache.camel.util.ObjectHelper; import org.apache.camel.utils.cassandra.CassandraExtraCodecs; import org.apache.camel.utils.cassandra.CassandraSessionHolder; @@ -174,7 +174,7 @@ public class CassandraEndpoint extends ScheduledPollEndpoint { System.err.println(c.toString()); for (String codec: c ) { - if (CassandraExtraCodecs.valueOf(codec).codec() != null) { + if (ObjectHelper.isNotEmpty(CassandraExtraCodecs.valueOf(codec))) { sessionBuilder.addTypeCodecs(CassandraExtraCodecs.valueOf(codec).codec()); } }