This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit b0ecd964e0079b40c67a455fcaa0b1ffbf5d27bc Author: Chirag <[email protected]> AuthorDate: Thu Jan 27 00:23:31 2022 -0500 correcting documentation and test cases (#6832) * correcting documentation and test cases Updating documentation and test cases to use databaseHistoryFileFilename. * applying correction to databaseHostname changed examples to use correct property / parameter databaseHostname * correcting databaseHostname Correcting databaseHostname in sample programs. --- .../src/main/docs/debezium-mongodb-component.adoc | 2 +- .../apache/camel/component/debezium/DebeziumMongodbComponentTest.java | 4 ++-- .../camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc | 2 +- .../apache/camel/component/debezium/DebeziumMySqlComponentTest.java | 4 ++-- .../src/main/docs/debezium-postgres-component.adoc | 2 +- .../camel/component/debezium/DebeziumPostgresComponentTest.java | 4 ++-- .../src/main/docs/debezium-sqlserver-component.adoc | 2 +- .../camel/component/debezium/DebeziumSqlserverComponentTest.java | 4 ++-- 8 files changed, 12 insertions(+), 12 deletions(-) diff --git a/components/camel-debezium/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc b/components/camel-debezium/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc index 4a0c1fc..84e68fc 100644 --- a/components/camel-debezium/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc +++ b/components/camel-debezium/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc @@ -90,7 +90,7 @@ Here is a very simple route that you can use in order to listen to Debezium even [source,java] ---- -from("debezium-mongodb:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&mongodbHosts=rs0/localhost:27017&mongodbUser=debezium&mongodbPassword=dbz&mongodbName=dbserver1&databaseHistoryFileName=/usr/history-file-1.dat") +from("debezium-mongodb:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&mongodbHosts=rs0/localhost:27017&mongodbUser=debezium&mongodbPassword=dbz&mongodbName=dbserver1&databaseHistoryFileFilename=/usr/history-file-1.dat") .log("Event received from Debezium : ${body}") .log(" with this identifier ${headers.CamelDebeziumIdentifier}") .log(" with these source metadata ${headers.CamelDebeziumSourceMetadata}") diff --git a/components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/DebeziumMongodbComponentTest.java b/components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/DebeziumMongodbComponentTest.java index 3b7cd8d..575d7f6 100644 --- a/components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/DebeziumMongodbComponentTest.java +++ b/components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/DebeziumMongodbComponentTest.java @@ -41,8 +41,8 @@ public class DebeziumMongodbComponentTest { final String remaining = "test_name"; final String uri = "debezium?name=test_name&offsetStorageFileName=/test&" - + "databaseHostName=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" - + "databaseServerName=test&databaseHistoryFileName=/test"; + + "databaseHostname=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" + + "databaseServerName=test&databaseHistoryFileFilename=/test"; try (final DebeziumComponent debeziumComponent = new DebeziumMongodbComponent(new DefaultCamelContext())) { debeziumComponent.start(); diff --git a/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc b/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc index a02880d..8370094 100644 --- a/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc +++ b/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc @@ -96,7 +96,7 @@ The message body if is not `null` (in case of tombstones), it contains the state Here is a very simple route that you can use in order to listen to Debezium events from MySQL connector. [source,java] ---- -from("debezium-mysql:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&databaseHostName=localhost&databaseUser=debezium&databasePassword=dbz&databaseServerName=my-app-connector&databaseHistoryFileName=/usr/history-file-1.dat") +from("debezium-mysql:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&databaseHostname=localhost&databaseUser=debezium&databasePassword=dbz&databaseServerName=my-app-connector&databaseHistoryFileFilename=/usr/history-file-1.dat") .log("Event received from Debezium : ${body}") .log(" with this identifier ${headers.CamelDebeziumIdentifier}") .log(" with these source metadata ${headers.CamelDebeziumSourceMetadata}") diff --git a/components/camel-debezium/camel-debezium-mysql/src/test/java/org/apache/camel/component/debezium/DebeziumMySqlComponentTest.java b/components/camel-debezium/camel-debezium-mysql/src/test/java/org/apache/camel/component/debezium/DebeziumMySqlComponentTest.java index 9e63cb3..0e6490e 100644 --- a/components/camel-debezium/camel-debezium-mysql/src/test/java/org/apache/camel/component/debezium/DebeziumMySqlComponentTest.java +++ b/components/camel-debezium/camel-debezium-mysql/src/test/java/org/apache/camel/component/debezium/DebeziumMySqlComponentTest.java @@ -42,8 +42,8 @@ public class DebeziumMySqlComponentTest { final String remaining = "test_name"; final String uri = "debezium:mysql?name=test_name&offsetStorageFileName=/test&" - + "databaseHostName=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" - + "databaseServerName=test&databaseHistoryFileName=/test"; + + "databaseHostname=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" + + "databaseServerName=test&databaseHistoryFileFilename=/test"; try (final DebeziumComponent debeziumComponent = new DebeziumMySqlComponent(new DefaultCamelContext())) { debeziumComponent.start(); diff --git a/components/camel-debezium/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc b/components/camel-debezium/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc index cd7f46f..e6bb4ff 100644 --- a/components/camel-debezium/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc +++ b/components/camel-debezium/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc @@ -87,7 +87,7 @@ Here is a very simple route that you can use in order to listen to Debezium even [source,java] ---- -from("debezium-postgres:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&databaseHostName=localhost&databaseUser=debezium&databasePassword=dbz&databaseServerName=my-app-connector&databaseHistoryFileName=/usr/history-file-1.dat") +from("debezium-postgres:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&databaseHostname=localhost&databaseUser=debezium&databasePassword=dbz&databaseServerName=my-app-connector&databaseHistoryFileFilename=/usr/history-file-1.dat") .log("Event received from Debezium : ${body}") .log(" with this identifier ${headers.CamelDebeziumIdentifier}") .log(" with these source metadata ${headers.CamelDebeziumSourceMetadata}") diff --git a/components/camel-debezium/camel-debezium-postgres/src/test/java/org/apache/camel/component/debezium/DebeziumPostgresComponentTest.java b/components/camel-debezium/camel-debezium-postgres/src/test/java/org/apache/camel/component/debezium/DebeziumPostgresComponentTest.java index 2f9eb38..620abb4 100644 --- a/components/camel-debezium/camel-debezium-postgres/src/test/java/org/apache/camel/component/debezium/DebeziumPostgresComponentTest.java +++ b/components/camel-debezium/camel-debezium-postgres/src/test/java/org/apache/camel/component/debezium/DebeziumPostgresComponentTest.java @@ -42,8 +42,8 @@ public class DebeziumPostgresComponentTest { final String remaining = "test_name"; final String uri = "debezium?name=test_name&offsetStorageFileName=/test&" - + "databaseHostName=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" - + "databaseServerName=test&databaseHistoryFileName=/test"; + + "databaseHostname=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" + + "databaseServerName=test&databaseHistoryFileFilename=/test"; try (final DebeziumComponent debeziumComponent = new DebeziumPostgresComponent(new DefaultCamelContext())) { debeziumComponent.start(); diff --git a/components/camel-debezium/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc b/components/camel-debezium/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc index 3dc5996..59cbfd1 100644 --- a/components/camel-debezium/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc +++ b/components/camel-debezium/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc @@ -85,7 +85,7 @@ Here is a very simple route that you can use in order to listen to Debezium even [source,java] ---- -from("debezium-sqlserver:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&databaseHostName=localhost&databaseUser=debezium&databasePassword=dbz&databaseServerName=my-app-connector&databaseHistoryFileName=/usr/history-file-1.dat") +from("debezium-sqlserver:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&databaseHostname=localhost&databaseUser=debezium&databasePassword=dbz&databaseServerName=my-app-connector&databaseHistoryFileFilename=/usr/history-file-1.dat") .log("Event received from Debezium : ${body}") .log(" with this identifier ${headers.CamelDebeziumIdentifier}") .log(" with these source metadata ${headers.CamelDebeziumSourceMetadata}") diff --git a/components/camel-debezium/camel-debezium-sqlserver/src/test/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentTest.java b/components/camel-debezium/camel-debezium-sqlserver/src/test/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentTest.java index b01a6df..4881673 100644 --- a/components/camel-debezium/camel-debezium-sqlserver/src/test/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentTest.java +++ b/components/camel-debezium/camel-debezium-sqlserver/src/test/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentTest.java @@ -42,8 +42,8 @@ public class DebeziumSqlserverComponentTest { final String remaining = "test_name"; final String uri = "debezium?name=test_name&offsetStorageFileName=/test&" - + "databaseHostName=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" - + "databaseServerName=test&databaseHistoryFileName=/test"; + + "databaseHostname=localhost&databaseServerId=1234&databaseUser=dbz&databasePassword=pwd&" + + "databaseServerName=test&databaseHistoryFileFilename=/test"; try (final DebeziumComponent debeziumComponent = new DebeziumSqlserverComponent(new DefaultCamelContext())) { debeziumComponent.start();
