This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8dd4de12b4d906d7014a2670c79fb16dcef3b40a Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Wed Mar 29 10:09:58 2023 +0200 (chores) camel-cassandra: use a logger instead of standard error output --- .../apache/camel/component/cassandra/CassandraEndpoint.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) 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 371260fc5b2..c1843875670 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 @@ -17,6 +17,7 @@ package org.apache.camel.component.cassandra; import java.net.InetSocketAddress; +import java.util.Arrays; import com.datastax.oss.driver.api.core.ConsistencyLevel; import com.datastax.oss.driver.api.core.CqlSession; @@ -41,6 +42,8 @@ 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; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Integrate with Cassandra 2.0+ using the CQL3 API (not the Thrift API). Based on Cassandra Java Driver provided by @@ -49,6 +52,7 @@ import org.apache.camel.utils.cassandra.CassandraSessionHolder; @UriEndpoint(firstVersion = "2.15.0", scheme = "cql", title = "Cassandra CQL", syntax = "cql:beanRef:hosts:port/keyspace", category = { Category.DATABASE, Category.NOSQL }, headersClass = CassandraConstants.class) public class CassandraEndpoint extends ScheduledPollEndpoint { + private static final Logger LOG = LoggerFactory.getLogger(CassandraEndpoint.class); private volatile CassandraSessionHolder sessionHolder; @@ -165,7 +169,11 @@ public class CassandraEndpoint extends ScheduledPollEndpoint { if (extraTypeCodecs != null) { String[] c = extraTypeCodecs.split(","); - System.err.println(c.toString()); + + if (LOG.isDebugEnabled()) { + LOG.debug(Arrays.toString(c)); + } + for (String codec : c) { if (ObjectHelper.isNotEmpty(CassandraExtraCodecs.valueOf(codec))) { sessionBuilder.addTypeCodecs(CassandraExtraCodecs.valueOf(codec).codec());