[camel] branch master updated: CAMEL-12517 - Camel-MongoDB and Camel-MongoDB3: Make them extends DefaultComponent

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino 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 42c34c3  CAMEL-12517 - Camel-MongoDB and Camel-MongoDB3: Make them 
extends DefaultComponent
42c34c3 is described below

commit 42c34c3abb3c46595e8530095a3965ddffe088f1
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed May 16 11:07:08 2018 +0200

    CAMEL-12517 - Camel-MongoDB and Camel-MongoDB3: Make them extends 
DefaultComponent
---
 .../apache/camel/component/mongodb/MongoDbComponent.java   | 13 +++++++++----
 .../apache/camel/component/mongodb3/MongoDbComponent.java  | 14 +++++++++-----
 2 files changed, 18 insertions(+), 9 deletions(-)

diff --git 
a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
 
b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
index e31ed97..405c881 100644
--- 
a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
+++ 
b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
@@ -21,15 +21,16 @@ import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
 
+import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
-import org.apache.camel.impl.UriEndpointComponent;
+import org.apache.camel.impl.DefaultComponent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
  * Represents the component that manages {@link MongoDbEndpoint}.
  */
-public class MongoDbComponent extends UriEndpointComponent {
+public class MongoDbComponent extends DefaultComponent {
     
     public static final Set<MongoDbOperation> WRITE_OPERATIONS = 
             new HashSet<>(Arrays.asList(MongoDbOperation.insert, 
MongoDbOperation.save, 
@@ -38,10 +39,14 @@ public class MongoDbComponent extends UriEndpointComponent {
     private static final Logger LOG = 
LoggerFactory.getLogger(MongoDbComponent.class);
 
     public MongoDbComponent() {
-        super(MongoDbEndpoint.class);
+        this(null);
     }
 
-    protected Endpoint createEndpoint(String uri, String remaining, 
Map<String, Object> parameters) throws Exception {
+    public MongoDbComponent(CamelContext context) {
+       super(context);
+       }
+
+       protected Endpoint createEndpoint(String uri, String remaining, 
Map<String, Object> parameters) throws Exception {
 
         MongoDbEndpoint endpoint = new MongoDbEndpoint(uri, this);
         endpoint.setConnectionBean(remaining);
diff --git 
a/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbComponent.java
 
b/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbComponent.java
index 741ead0..c34c1d5 100644
--- 
a/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbComponent.java
+++ 
b/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbComponent.java
@@ -21,26 +21,30 @@ import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
 
-
+import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
-import org.apache.camel.impl.UriEndpointComponent;
+import org.apache.camel.impl.DefaultComponent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
  * Represents the component that manages {@link MongoDbEndpoint}.
  */
-public class MongoDbComponent extends UriEndpointComponent {
+public class MongoDbComponent extends DefaultComponent {
 
     public static final Set<MongoDbOperation> WRITE_OPERATIONS = new 
HashSet<>(Arrays.asList(MongoDbOperation.insert, MongoDbOperation.save, 
MongoDbOperation.update,
                                                                                
              MongoDbOperation.remove));
     private static final Logger LOG = 
LoggerFactory.getLogger(MongoDbComponent.class);
 
     public MongoDbComponent() {
-        super(MongoDbEndpoint.class);
+        this(null);
     }
 
-    protected Endpoint createEndpoint(String uri, String remaining, 
Map<String, Object> parameters) throws Exception {
+    public MongoDbComponent(CamelContext context) {
+               super(context);
+       }
+
+       protected Endpoint createEndpoint(String uri, String remaining, 
Map<String, Object> parameters) throws Exception {
 
         MongoDbEndpoint endpoint = new MongoDbEndpoint(uri, this);
         endpoint.setConnectionBean(remaining);

-- 
To stop receiving notification emails like this one, please contact
acosent...@apache.org.