This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit b855fca5ee7d1e702a64ea57028250e1c98a7a3a Author: Omar Al-Safi <omars...@gmail.com> AuthorDate: Mon Sep 16 14:44:32 2019 +0200 CAMEL-13964: Remove the invocation of PropertiesComponent --- .../apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java | 3 --- .../org/apache/camel/example/debezium/KinesisProducerToCassandra.java | 3 --- 2 files changed, 6 deletions(-) diff --git a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java index f4b9550..86335ea 100644 --- a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java +++ b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java @@ -49,9 +49,6 @@ public final class DebeziumMySqlConsumerToKinesis { // add route main.addRouteBuilder(new RouteBuilder() { public void configure() { - final PropertiesComponent pc = getContext().getComponent("properties", PropertiesComponent.class); - pc.setLocation("classpath:application.properties"); - // Initial Debezium route that will run and listens to the changes, // first it will perform an initial snapshot using (select * from) in case there are no offsets // exists for the connector and then it will listens to MySQL binlogs for any DB events such as (UPDATE, INSERT and DELETE) diff --git a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java index 846f3d7..a31b093 100644 --- a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java +++ b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java @@ -47,9 +47,6 @@ public final class KinesisProducerToCassandra { // add route main.addRouteBuilder(new RouteBuilder() { public void configure() { - final PropertiesComponent pc = getContext().getComponent("properties", PropertiesComponent.class); - pc.setLocation("classpath:application.properties"); - // We set the CQL templates we need, note that an UPDATE in Cassandra means an UPSERT which is what we need final String cqlUpdate = "update products set name = ?, description = ?, weight = ? where id = ?"; final String cqlDelete = "delete from products where id = ?";