You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/10/30 08:16:23 UTC
[camel] branch master updated: Camel 14090: Break camel-debezium
into camel-debezium-common and camel-debezium-mysql
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
The following commit(s) were added to refs/heads/master by this push:
new c2586d1 Camel 14090: Break camel-debezium into camel-debezium-common and camel-debezium-mysql
c2586d1 is described below
commit c2586d1cc6694e3883fa1875a0d3ae8fd9b539af
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Oct 30 09:16:00 2019 +0100
Camel 14090: Break camel-debezium into camel-debezium-common and camel-debezium-mysql
---
...va => DebeziumMySqlEndpointBuilderFactory.java} | 64 ++++++++++++----------
1 file changed, 35 insertions(+), 29 deletions(-)
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
similarity index 59%
rename from core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumEndpointBuilderFactory.java
rename to core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index bd4ae72..af1da2e 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -22,32 +22,35 @@ import org.apache.camel.builder.EndpointProducerBuilder;
import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
/**
- * Represents a Debezium endpoint which is used for interacting with Debezium
- * embedded engine.
+ * Represents a Debezium MySQL endpoint which is used to capture changes in
+ * MySQL database so that that applications can see those changes and respond to
+ * them.
*
* Generated by camel-package-maven-plugin - do not edit this file!
*/
@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface DebeziumEndpointBuilderFactory {
+public interface DebeziumMySqlEndpointBuilderFactory {
/**
- * Builder for endpoint for the Debezium component.
+ * Builder for endpoint for the Debezium MySQL Connector component.
*/
- public interface DebeziumEndpointBuilder extends EndpointConsumerBuilder {
- default AdvancedDebeziumEndpointBuilder advanced() {
- return (AdvancedDebeziumEndpointBuilder) this;
+ public interface DebeziumMySqlEndpointBuilder
+ extends
+ EndpointConsumerBuilder {
+ default AdvancedDebeziumMySqlEndpointBuilder advanced() {
+ return (AdvancedDebeziumMySqlEndpointBuilder) this;
}
}
/**
- * Advanced builder for endpoint for the Debezium component.
+ * Advanced builder for endpoint for the Debezium MySQL Connector component.
*/
- public interface AdvancedDebeziumEndpointBuilder
+ public interface AdvancedDebeziumMySqlEndpointBuilder
extends
EndpointConsumerBuilder {
- default DebeziumEndpointBuilder basic() {
- return (DebeziumEndpointBuilder) this;
+ default DebeziumMySqlEndpointBuilder basic() {
+ return (DebeziumMySqlEndpointBuilder) this;
}
/**
* Whether the endpoint should use basic property binding (Camel 2.x) or
@@ -57,7 +60,7 @@ public interface DebeziumEndpointBuilderFactory {
*
* Group: advanced
*/
- default AdvancedDebeziumEndpointBuilder basicPropertyBinding(
+ default AdvancedDebeziumMySqlEndpointBuilder basicPropertyBinding(
boolean basicPropertyBinding) {
doSetProperty("basicPropertyBinding", basicPropertyBinding);
return this;
@@ -70,7 +73,7 @@ public interface DebeziumEndpointBuilderFactory {
*
* Group: advanced
*/
- default AdvancedDebeziumEndpointBuilder basicPropertyBinding(
+ default AdvancedDebeziumMySqlEndpointBuilder basicPropertyBinding(
String basicPropertyBinding) {
doSetProperty("basicPropertyBinding", basicPropertyBinding);
return this;
@@ -83,7 +86,8 @@ public interface DebeziumEndpointBuilderFactory {
*
* Group: advanced
*/
- default AdvancedDebeziumEndpointBuilder synchronous(boolean synchronous) {
+ default AdvancedDebeziumMySqlEndpointBuilder synchronous(
+ boolean synchronous) {
doSetProperty("synchronous", synchronous);
return this;
}
@@ -95,32 +99,34 @@ public interface DebeziumEndpointBuilderFactory {
*
* Group: advanced
*/
- default AdvancedDebeziumEndpointBuilder synchronous(String synchronous) {
+ default AdvancedDebeziumMySqlEndpointBuilder synchronous(
+ String synchronous) {
doSetProperty("synchronous", synchronous);
return this;
}
}
/**
- * Debezium (camel-debezium)
- * Represents a Debezium endpoint which is used for interacting with
- * Debezium embedded engine.
+ * Debezium MySQL Connector (camel-debezium-mysql)
+ * Represents a Debezium MySQL endpoint which is used to capture changes in
+ * MySQL database so that that applications can see those changes and
+ * respond to them.
*
- * Category: database,sql,nosql
+ * Category: database,sql,mysql
* Available as of version: 3.0
- * Maven coordinates: org.apache.camel:camel-debezium
+ * Maven coordinates: org.apache.camel:camel-debezium-mysql
*
- * Syntax: <code>debezium:connectorType</code>
+ * Syntax: <code>debezium-mysql:name</code>
*
- * Path parameter: connectorType (required)
- * The Debezium connector type that is supported by Camel Debezium
- * component.
+ * Path parameter: name (required)
+ * Unique name for the connector. Attempting to register again with the same
+ * name will fail.
*/
- default DebeziumEndpointBuilder debezium(String path) {
- class DebeziumEndpointBuilderImpl extends AbstractEndpointBuilder implements DebeziumEndpointBuilder, AdvancedDebeziumEndpointBuilder {
- public DebeziumEndpointBuilderImpl(String path) {
- super("debezium", path);
+ default DebeziumMySqlEndpointBuilder debeziumMysql(String path) {
+ class DebeziumMySqlEndpointBuilderImpl extends AbstractEndpointBuilder implements DebeziumMySqlEndpointBuilder, AdvancedDebeziumMySqlEndpointBuilder {
+ public DebeziumMySqlEndpointBuilderImpl(String path) {
+ super("debezium-mysql", path);
}
}
- return new DebeziumEndpointBuilderImpl(path);
+ return new DebeziumMySqlEndpointBuilderImpl(path);
}
}
\ No newline at end of file