You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/09 06:31:08 UTC

[camel-kafka-connector] branch align-3.6.0 created (now c6cb7d3)

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

acosentino pushed a change to branch align-3.6.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


      at c6cb7d3  CamelKafkaConnectorMain: Aligned with the improvements in BaseMainSupport and MainSupport

This branch includes the following new commits:

     new c6cb7d3  CamelKafkaConnectorMain: Aligned with the improvements in BaseMainSupport and MainSupport

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[camel-kafka-connector] 01/01: CamelKafkaConnectorMain: Aligned with the improvements in BaseMainSupport and MainSupport

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch align-3.6.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit c6cb7d34d676843bd60736127b787d76fe06521c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 9 08:30:22 2020 +0200

    CamelKafkaConnectorMain: Aligned with the improvements in BaseMainSupport and MainSupport
---
 .../camel/kafkaconnector/utils/CamelKafkaConnectMain.java      | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 4150dea..6f1b187 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -97,16 +97,6 @@ public class CamelKafkaConnectMain extends BaseMainSupport {
         LOG.info("Main stopped");
     }
 
-    @Override
-    protected ProducerTemplate findOrCreateCamelTemplate() {
-        throw new UnsupportedOperationException("Should not happen");
-    }
-
-    @Override
-    protected CamelContext createCamelContext() {
-        throw new UnsupportedOperationException("Should not happen");
-    }
-
     public ProducerTemplate getProducerTemplate() {
         if (this.producerTemplate == null) {
             synchronized (this) {