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

gnodet pushed a commit to branch endpoint-dsl
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/endpoint-dsl by this push:
     new ea31f20  Remove unneeded generated classes for endpoints that are 
consumer/producer only
ea31f20 is described below

commit ea31f20ada7d6bf7faa656d93672e2fb592b6189
Author: Guillaume Nodet <gno...@gmail.com>
AuthorDate: Thu Jun 6 12:39:21 2019 +0200

    Remove unneeded generated classes for endpoints that are consumer/producer 
only
---
 .../apache/camel/model/endpoint/AhcEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/AtomEndpoint.java  | 10 -----
 .../model/endpoint/AtomixMultiMapEndpoint.java     | 10 -----
 .../apache/camel/model/endpoint/BeanEndpoint.java  | 10 -----
 .../model/endpoint/BeanValidatorEndpoint.java      | 10 -----
 .../camel/model/endpoint/BonitaEndpoint.java       | 10 -----
 .../apache/camel/model/endpoint/CMEndpoint.java    | 10 -----
 .../camel/model/endpoint/ChatScriptEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/ChunkEndpoint.java | 10 -----
 .../camel/model/endpoint/CinderEndpoint.java       | 10 -----
 .../apache/camel/model/endpoint/ClassEndpoint.java | 10 -----
 .../camel/model/endpoint/ControlBusEndpoint.java   | 10 -----
 .../camel/model/endpoint/CryptoCmsEndpoint.java    | 10 -----
 .../apache/camel/model/endpoint/CwEndpoint.java    | 10 -----
 .../camel/model/endpoint/DataFormatEndpoint.java   | 10 -----
 .../camel/model/endpoint/DataSetTestEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/DdbEndpoint.java   | 10 -----
 .../camel/model/endpoint/DdbStreamEndpoint.java    | 10 -----
 .../camel/model/endpoint/DigitalOceanEndpoint.java | 10 -----
 .../model/endpoint/DigitalSignatureEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/DnsEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/DozerEndpoint.java | 10 -----
 .../apache/camel/model/endpoint/DrillEndpoint.java | 10 -----
 .../apache/camel/model/endpoint/EC2Endpoint.java   | 10 -----
 .../apache/camel/model/endpoint/ECSEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/EKSEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/EjbEndpoint.java   | 10 -----
 .../model/endpoint/ElasticsearchEndpoint.java      | 10 -----
 .../apache/camel/model/endpoint/ExecEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/FlinkEndpoint.java | 10 -----
 .../apache/camel/model/endpoint/FopEndpoint.java   | 10 -----
 .../camel/model/endpoint/FreemarkerEndpoint.java   | 10 -----
 .../camel/model/endpoint/GangliaEndpoint.java      | 10 -----
 .../camel/model/endpoint/GeoCoderEndpoint.java     | 10 -----
 .../camel/model/endpoint/GlanceEndpoint.java       | 10 -----
 .../model/endpoint/GoogleBigQueryEndpoint.java     | 10 -----
 .../model/endpoint/GoogleBigQuerySQLEndpoint.java  | 10 -----
 .../endpoint/GoogleCalendarStreamEndpoint.java     | 10 -----
 .../model/endpoint/GoogleMailStreamEndpoint.java   | 10 -----
 .../model/endpoint/GoogleSheetsStreamEndpoint.java | 10 -----
 .../apache/camel/model/endpoint/GrapeEndpoint.java | 10 -----
 .../endpoint/HazelcastAtomicnumberEndpoint.java    | 10 -----
 .../model/endpoint/HazelcastInstanceEndpoint.java  | 10 -----
 .../endpoint/HazelcastRingbufferEndpoint.java      | 10 -----
 .../apache/camel/model/endpoint/HttpEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/IAMEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/IPFSEndpoint.java  | 10 -----
 .../model/endpoint/IgniteComputeEndpoint.java      | 10 -----
 .../camel/model/endpoint/IgniteEventsEndpoint.java | 10 -----
 .../camel/model/endpoint/IgniteIdGenEndpoint.java  | 10 -----
 .../camel/model/endpoint/IgniteQueueEndpoint.java  | 10 -----
 .../camel/model/endpoint/IgniteSetEndpoint.java    | 10 -----
 .../camel/model/endpoint/InfluxDbEndpoint.java     | 10 -----
 .../apache/camel/model/endpoint/JMXEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/JdbcEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/JingEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/JoltEndpoint.java  | 10 -----
 .../model/endpoint/JsonValidatorEndpoint.java      | 10 -----
 .../apache/camel/model/endpoint/KMSEndpoint.java   | 10 -----
 .../camel/model/endpoint/KeystoneEndpoint.java     | 10 -----
 .../model/endpoint/KinesisFirehoseEndpoint.java    | 10 -----
 .../endpoint/KubernetesConfigMapsEndpoint.java     | 10 -----
 .../KubernetesPersistentVolumesClaimsEndpoint.java | 10 -----
 .../KubernetesPersistentVolumesEndpoint.java       | 10 -----
 .../endpoint/KubernetesResourcesQuotaEndpoint.java | 10 -----
 .../model/endpoint/KubernetesSecretsEndpoint.java  | 10 -----
 .../KubernetesServiceAccountsEndpoint.java         | 10 -----
 .../camel/model/endpoint/LambdaEndpoint.java       | 10 -----
 .../camel/model/endpoint/LanguageEndpoint.java     | 10 -----
 .../apache/camel/model/endpoint/LdapEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/LdifEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/LogEndpoint.java   | 10 -----
 .../camel/model/endpoint/LuceneEndpoint.java       | 10 -----
 .../camel/model/endpoint/LumberjackEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/MQEndpoint.java    | 10 -----
 .../apache/camel/model/endpoint/MSKEndpoint.java   | 10 -----
 .../camel/model/endpoint/MasterEndpoint.java       | 10 -----
 .../camel/model/endpoint/MetricsEndpoint.java      | 10 -----
 .../camel/model/endpoint/MicrometerEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/MockEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/MsvEndpoint.java   | 10 -----
 .../camel/model/endpoint/MustacheEndpoint.java     | 10 -----
 .../apache/camel/model/endpoint/MvelEndpoint.java  | 10 -----
 .../camel/model/endpoint/MyBatisBeanEndpoint.java  | 10 -----
 .../camel/model/endpoint/NagiosEndpoint.java       | 10 -----
 .../camel/model/endpoint/NetWeaverEndpoint.java    | 10 -----
 .../camel/model/endpoint/NeutronEndpoint.java      | 10 -----
 .../apache/camel/model/endpoint/NovaEndpoint.java  | 10 -----
 .../endpoint/OpenshiftBuildConfigsEndpoint.java    | 10 -----
 .../model/endpoint/OpenshiftBuildsEndpoint.java    | 10 -----
 .../camel/model/endpoint/PaxLoggingEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/PdfEndpoint.java   | 10 -----
 .../camel/model/endpoint/PrinterEndpoint.java      | 10 -----
 .../camel/model/endpoint/QuartzEndpoint.java       | 10 -----
 .../camel/model/endpoint/RestApiEndpoint.java      | 10 -----
 .../camel/model/endpoint/RestSwaggerEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/RssEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/SagaEndpoint.java  | 10 -----
 .../camel/model/endpoint/SchedulerEndpoint.java    | 10 -----
 .../camel/model/endpoint/SchematronEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/ScpEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/SdbEndpoint.java   | 10 -----
 .../camel/model/endpoint/ServiceEndpoint.java      | 10 -----
 .../camel/model/endpoint/ServiceNowEndpoint.java   | 10 -----
 .../camel/model/endpoint/ServletEndpoint.java      | 10 -----
 .../apache/camel/model/endpoint/SesEndpoint.java   | 10 -----
 .../camel/model/endpoint/SjmsBatchEndpoint.java    | 10 -----
 .../apache/camel/model/endpoint/SnmpEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/SnsEndpoint.java   | 10 -----
 .../apache/camel/model/endpoint/SolrEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/SparkEndpoint.java | 10 -----
 .../camel/model/endpoint/SpringBatchEndpoint.java  | 10 -----
 .../camel/model/endpoint/SpringLdapEndpoint.java   | 10 -----
 .../camel/model/endpoint/SqlStoredEndpoint.java    | 10 -----
 .../apache/camel/model/endpoint/StAXEndpoint.java  | 10 -----
 .../model/endpoint/StringTemplateEndpoint.java     | 10 -----
 .../apache/camel/model/endpoint/SwiftEndpoint.java | 10 -----
 .../apache/camel/model/endpoint/TikaEndpoint.java  | 10 -----
 .../apache/camel/model/endpoint/TimerEndpoint.java | 10 -----
 .../model/endpoint/TwitterStreamingEndpoint.java   | 10 -----
 .../camel/model/endpoint/ValidatorEndpoint.java    | 10 -----
 .../camel/model/endpoint/VelocityEndpoint.java     | 10 -----
 .../camel/model/endpoint/WebhookEndpoint.java      | 10 -----
 .../camel/model/endpoint/XChangeEndpoint.java      | 10 -----
 .../camel/model/endpoint/XmlSignatureEndpoint.java | 10 -----
 .../apache/camel/model/endpoint/XsltEndpoint.java  | 10 -----
 .../model/endpoint/ZooKeeperMasterEndpoint.java    | 10 -----
 .../camel/maven/packaging/EndpointDslMojo.java     | 49 +++++++++++++---------
 128 files changed, 30 insertions(+), 1289 deletions(-)

diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AhcEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AhcEndpoint.java
index bdfd604..699874f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AhcEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AhcEndpoint.java
@@ -168,16 +168,6 @@ public class AhcEndpoint {
         }
     }
 
-    public static class AhcConsumer
-            extends
-                AhcCommon<AhcConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public AhcConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class AhcProducer
             extends
                 AhcCommon<AhcProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomEndpoint.java
index a6fb49b..6a68a76 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomEndpoint.java
@@ -321,14 +321,4 @@ public class AtomEndpoint {
             return (AtomConsumer) this;
         }
     }
-
-    public static class AtomProducer
-            extends
-                AtomCommon<AtomProducer>
-            implements
-                EndpointDefinition.Producer {
-        public AtomProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomixMultiMapEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomixMultiMapEndpoint.java
index 7599d49..d0e6cae 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomixMultiMapEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/AtomixMultiMapEndpoint.java
@@ -223,16 +223,6 @@ public class AtomixMultiMapEndpoint {
         }
     }
 
-    public static class AtomixMultiMapProducer
-            extends
-                AtomixMultiMapCommon<AtomixMultiMapProducer>
-            implements
-                EndpointDefinition.Producer {
-        public AtomixMultiMapProducer(String path) {
-            super(path);
-        }
-    }
-
     public static enum ReadConsistency {
         ATOMIC, ATOMIC_LEASE, SEQUENTIAL, LOCAL;
     }
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanEndpoint.java
index e474352..dd88fef 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanEndpoint.java
@@ -88,16 +88,6 @@ public class BeanEndpoint {
         }
     }
 
-    public static class BeanConsumer
-            extends
-                BeanCommon<BeanConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public BeanConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class BeanProducer
             extends
                 BeanCommon<BeanProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanValidatorEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanValidatorEndpoint.java
index 8863f22..a155b92 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanValidatorEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BeanValidatorEndpoint.java
@@ -103,16 +103,6 @@ public class BeanValidatorEndpoint {
         }
     }
 
-    public static class BeanValidatorConsumer
-            extends
-                BeanValidatorCommon<BeanValidatorConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public BeanValidatorConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class BeanValidatorProducer
             extends
                 BeanValidatorCommon<BeanValidatorProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BonitaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BonitaEndpoint.java
index 25e9c16..0bd787a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BonitaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/BonitaEndpoint.java
@@ -146,16 +146,6 @@ public class BonitaEndpoint {
         }
     }
 
-    public static class BonitaProducer
-            extends
-                BonitaCommon<BonitaProducer>
-            implements
-                EndpointDefinition.Producer {
-        public BonitaProducer(String path) {
-            super(path);
-        }
-    }
-
     public static enum BonitaOperation {
         startCase;
     }
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CMEndpoint.java 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CMEndpoint.java
index 0db44ef..17ab458 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CMEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CMEndpoint.java
@@ -98,16 +98,6 @@ public class CMEndpoint {
         }
     }
 
-    public static class CMConsumer
-            extends
-                CMCommon<CMConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public CMConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class CMProducer
             extends
                 CMCommon<CMProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChatScriptEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChatScriptEndpoint.java
index d91091d..8d7b3c0 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChatScriptEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChatScriptEndpoint.java
@@ -93,16 +93,6 @@ public class ChatScriptEndpoint {
         }
     }
 
-    public static class ChatScriptConsumer
-            extends
-                ChatScriptCommon<ChatScriptConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ChatScriptConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ChatScriptProducer
             extends
                 ChatScriptCommon<ChatScriptProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChunkEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChunkEndpoint.java
index d6b7857..1adcc5f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChunkEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ChunkEndpoint.java
@@ -114,16 +114,6 @@ public class ChunkEndpoint {
         }
     }
 
-    public static class ChunkConsumer
-            extends
-                ChunkCommon<ChunkConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ChunkConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ChunkProducer
             extends
                 ChunkCommon<ChunkProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CinderEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CinderEndpoint.java
index 2850b3a..21240e3 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CinderEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CinderEndpoint.java
@@ -119,16 +119,6 @@ public class CinderEndpoint {
         }
     }
 
-    public static class CinderConsumer
-            extends
-                CinderCommon<CinderConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public CinderConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class CinderProducer
             extends
                 CinderCommon<CinderProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ClassEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ClassEndpoint.java
index 78c01b5..98dace4 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ClassEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ClassEndpoint.java
@@ -88,16 +88,6 @@ public class ClassEndpoint {
         }
     }
 
-    public static class ClassConsumer
-            extends
-                ClassCommon<ClassConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ClassConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ClassProducer
             extends
                 ClassCommon<ClassProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ControlBusEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ControlBusEndpoint.java
index 06e82b2..772506e 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ControlBusEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ControlBusEndpoint.java
@@ -125,16 +125,6 @@ public class ControlBusEndpoint {
         }
     }
 
-    public static class ControlBusConsumer
-            extends
-                ControlBusCommon<ControlBusConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ControlBusConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ControlBusProducer
             extends
                 ControlBusCommon<ControlBusProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CryptoCmsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CryptoCmsEndpoint.java
index e675423..f83f783 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CryptoCmsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CryptoCmsEndpoint.java
@@ -225,16 +225,6 @@ public class CryptoCmsEndpoint {
         }
     }
 
-    public static class CryptoCmsConsumer
-            extends
-                CryptoCmsCommon<CryptoCmsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public CryptoCmsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class CryptoCmsProducer
             extends
                 CryptoCmsCommon<CryptoCmsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CwEndpoint.java 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CwEndpoint.java
index d2395ec..5c0308c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CwEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/CwEndpoint.java
@@ -136,16 +136,6 @@ public class CwEndpoint {
         }
     }
 
-    public static class CwConsumer
-            extends
-                CwCommon<CwConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public CwConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class CwProducer
             extends
                 CwCommon<CwProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataFormatEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataFormatEndpoint.java
index 05aa86e..d99829f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataFormatEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataFormatEndpoint.java
@@ -70,16 +70,6 @@ public class DataFormatEndpoint {
         }
     }
 
-    public static class DataFormatConsumer
-            extends
-                DataFormatCommon<DataFormatConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DataFormatConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DataFormatProducer
             extends
                 DataFormatCommon<DataFormatProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataSetTestEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataSetTestEndpoint.java
index 3954664..c0f5ca3 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataSetTestEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DataSetTestEndpoint.java
@@ -98,16 +98,6 @@ public class DataSetTestEndpoint {
         }
     }
 
-    public static class DataSetTestConsumer
-            extends
-                DataSetTestCommon<DataSetTestConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DataSetTestConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DataSetTestProducer
             extends
                 DataSetTestCommon<DataSetTestProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbEndpoint.java
index 2342a3f..ba692fc 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbEndpoint.java
@@ -157,16 +157,6 @@ public class DdbEndpoint {
         }
     }
 
-    public static class DdbConsumer
-            extends
-                DdbCommon<DdbConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DdbConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DdbProducer
             extends
                 DdbCommon<DdbProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbStreamEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbStreamEndpoint.java
index 23326c9..b326fe0 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbStreamEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DdbStreamEndpoint.java
@@ -333,16 +333,6 @@ public class DdbStreamEndpoint {
         }
     }
 
-    public static class DdbStreamProducer
-            extends
-                DdbStreamCommon<DdbStreamProducer>
-            implements
-                EndpointDefinition.Producer {
-        public DdbStreamProducer(String path) {
-            super(path);
-        }
-    }
-
     public static enum ShardIteratorType {
         TRIM_HORIZON, LATEST, AT_SEQUENCE_NUMBER, AFTER_SEQUENCE_NUMBER;
     }
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalOceanEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalOceanEndpoint.java
index c5b3656..b973851 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalOceanEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalOceanEndpoint.java
@@ -133,16 +133,6 @@ public class DigitalOceanEndpoint {
         }
     }
 
-    public static class DigitalOceanConsumer
-            extends
-                DigitalOceanCommon<DigitalOceanConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DigitalOceanConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DigitalOceanProducer
             extends
                 DigitalOceanCommon<DigitalOceanProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalSignatureEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalSignatureEndpoint.java
index d33c5dc..2cca698 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalSignatureEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DigitalSignatureEndpoint.java
@@ -239,16 +239,6 @@ public class DigitalSignatureEndpoint {
         }
     }
 
-    public static class DigitalSignatureConsumer
-            extends
-                DigitalSignatureCommon<DigitalSignatureConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DigitalSignatureConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DigitalSignatureProducer
             extends
                 DigitalSignatureCommon<DigitalSignatureProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DnsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DnsEndpoint.java
index 6bcfe9f..e2b7c6a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DnsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DnsEndpoint.java
@@ -62,16 +62,6 @@ public class DnsEndpoint {
         }
     }
 
-    public static class DnsConsumer
-            extends
-                DnsCommon<DnsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DnsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DnsProducer
             extends
                 DnsCommon<DnsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DozerEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DozerEndpoint.java
index 177cdf7..2f0b2fe 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DozerEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DozerEndpoint.java
@@ -122,16 +122,6 @@ public class DozerEndpoint {
         }
     }
 
-    public static class DozerConsumer
-            extends
-                DozerCommon<DozerConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DozerConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DozerProducer
             extends
                 DozerCommon<DozerProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DrillEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DrillEndpoint.java
index 21d47f3..6199b20 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DrillEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/DrillEndpoint.java
@@ -95,16 +95,6 @@ public class DrillEndpoint {
         }
     }
 
-    public static class DrillConsumer
-            extends
-                DrillCommon<DrillConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public DrillConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class DrillProducer
             extends
                 DrillCommon<DrillProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EC2Endpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EC2Endpoint.java
index 478261c..23c6ffe 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EC2Endpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EC2Endpoint.java
@@ -69,16 +69,6 @@ public class EC2Endpoint {
         }
     }
 
-    public static class EC2Consumer
-            extends
-                EC2Common<EC2Consumer>
-            implements
-                EndpointDefinition.Consumer {
-        public EC2Consumer(String path) {
-            super(path);
-        }
-    }
-
     public static class EC2Producer
             extends
                 EC2Common<EC2Producer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ECSEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ECSEndpoint.java
index 92eac6d..487be13 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ECSEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ECSEndpoint.java
@@ -69,16 +69,6 @@ public class ECSEndpoint {
         }
     }
 
-    public static class ECSConsumer
-            extends
-                ECSCommon<ECSConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ECSConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ECSProducer
             extends
                 ECSCommon<ECSProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EKSEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EKSEndpoint.java
index fced6c3..263351b 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EKSEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EKSEndpoint.java
@@ -69,16 +69,6 @@ public class EKSEndpoint {
         }
     }
 
-    public static class EKSConsumer
-            extends
-                EKSCommon<EKSConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public EKSConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class EKSProducer
             extends
                 EKSCommon<EKSProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EjbEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EjbEndpoint.java
index 043c06b..48aa2f0 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EjbEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/EjbEndpoint.java
@@ -88,16 +88,6 @@ public class EjbEndpoint {
         }
     }
 
-    public static class EjbConsumer
-            extends
-                EjbCommon<EjbConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public EjbConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class EjbProducer
             extends
                 EjbCommon<EjbProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ElasticsearchEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ElasticsearchEndpoint.java
index e77231d..f48637b 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ElasticsearchEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ElasticsearchEndpoint.java
@@ -155,16 +155,6 @@ public class ElasticsearchEndpoint {
         }
     }
 
-    public static class ElasticsearchConsumer
-            extends
-                ElasticsearchCommon<ElasticsearchConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ElasticsearchConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ElasticsearchProducer
             extends
                 ElasticsearchCommon<ElasticsearchProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ExecEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ExecEndpoint.java
index 87f1531..d1acc69 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ExecEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ExecEndpoint.java
@@ -126,16 +126,6 @@ public class ExecEndpoint {
         }
     }
 
-    public static class ExecConsumer
-            extends
-                ExecCommon<ExecConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ExecConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ExecProducer
             extends
                 ExecCommon<ExecProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FlinkEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FlinkEndpoint.java
index b5031b4..f917394 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FlinkEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FlinkEndpoint.java
@@ -102,16 +102,6 @@ public class FlinkEndpoint {
         }
     }
 
-    public static class FlinkConsumer
-            extends
-                FlinkCommon<FlinkConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public FlinkConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class FlinkProducer
             extends
                 FlinkCommon<FlinkProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FopEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FopEndpoint.java
index 56ad06b..f284951 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FopEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FopEndpoint.java
@@ -81,16 +81,6 @@ public class FopEndpoint {
         }
     }
 
-    public static class FopConsumer
-            extends
-                FopCommon<FopConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public FopConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class FopProducer
             extends
                 FopCommon<FopProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FreemarkerEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FreemarkerEndpoint.java
index c6f05ff..df4fbef 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FreemarkerEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/FreemarkerEndpoint.java
@@ -98,16 +98,6 @@ public class FreemarkerEndpoint {
         }
     }
 
-    public static class FreemarkerConsumer
-            extends
-                FreemarkerCommon<FreemarkerConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public FreemarkerConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class FreemarkerProducer
             extends
                 FreemarkerCommon<FreemarkerProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GangliaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GangliaEndpoint.java
index 87a712b..15f105a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GangliaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GangliaEndpoint.java
@@ -169,16 +169,6 @@ public class GangliaEndpoint {
         }
     }
 
-    public static class GangliaConsumer
-            extends
-                GangliaCommon<GangliaConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public GangliaConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class GangliaProducer
             extends
                 GangliaCommon<GangliaProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GeoCoderEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GeoCoderEndpoint.java
index 1db1e66..da6d433 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GeoCoderEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GeoCoderEndpoint.java
@@ -163,16 +163,6 @@ public class GeoCoderEndpoint {
         }
     }
 
-    public static class GeoCoderConsumer
-            extends
-                GeoCoderCommon<GeoCoderConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public GeoCoderConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class GeoCoderProducer
             extends
                 GeoCoderCommon<GeoCoderProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GlanceEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GlanceEndpoint.java
index 7227740..fd60e12 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GlanceEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GlanceEndpoint.java
@@ -112,16 +112,6 @@ public class GlanceEndpoint {
         }
     }
 
-    public static class GlanceConsumer
-            extends
-                GlanceCommon<GlanceConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public GlanceConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class GlanceProducer
             extends
                 GlanceCommon<GlanceProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQueryEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQueryEndpoint.java
index c702678..1c906b4 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQueryEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQueryEndpoint.java
@@ -92,16 +92,6 @@ public class GoogleBigQueryEndpoint {
         }
     }
 
-    public static class GoogleBigQueryConsumer
-            extends
-                GoogleBigQueryCommon<GoogleBigQueryConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public GoogleBigQueryConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class GoogleBigQueryProducer
             extends
                 GoogleBigQueryCommon<GoogleBigQueryProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQuerySQLEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQuerySQLEndpoint.java
index a4a266a..d2d15d6 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQuerySQLEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleBigQuerySQLEndpoint.java
@@ -77,16 +77,6 @@ public class GoogleBigQuerySQLEndpoint {
         }
     }
 
-    public static class GoogleBigQuerySQLConsumer
-            extends
-                GoogleBigQuerySQLCommon<GoogleBigQuerySQLConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public GoogleBigQuerySQLConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class GoogleBigQuerySQLProducer
             extends
                 GoogleBigQuerySQLCommon<GoogleBigQuerySQLProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleCalendarStreamEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleCalendarStreamEndpoint.java
index 13335f6..48bf989 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleCalendarStreamEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleCalendarStreamEndpoint.java
@@ -355,14 +355,4 @@ public class GoogleCalendarStreamEndpoint {
             return (GoogleCalendarStreamConsumer) this;
         }
     }
-
-    public static class GoogleCalendarStreamProducer
-            extends
-                GoogleCalendarStreamCommon<GoogleCalendarStreamProducer>
-            implements
-                EndpointDefinition.Producer {
-        public GoogleCalendarStreamProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleMailStreamEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleMailStreamEndpoint.java
index 88d60ad..78a125e 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleMailStreamEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleMailStreamEndpoint.java
@@ -334,14 +334,4 @@ public class GoogleMailStreamEndpoint {
             return (GoogleMailStreamConsumer) this;
         }
     }
-
-    public static class GoogleMailStreamProducer
-            extends
-                GoogleMailStreamCommon<GoogleMailStreamProducer>
-            implements
-                EndpointDefinition.Producer {
-        public GoogleMailStreamProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleSheetsStreamEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleSheetsStreamEndpoint.java
index 808e4c4..3116a7b 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleSheetsStreamEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GoogleSheetsStreamEndpoint.java
@@ -362,14 +362,4 @@ public class GoogleSheetsStreamEndpoint {
             return (GoogleSheetsStreamConsumer) this;
         }
     }
-
-    public static class GoogleSheetsStreamProducer
-            extends
-                GoogleSheetsStreamCommon<GoogleSheetsStreamProducer>
-            implements
-                EndpointDefinition.Producer {
-        public GoogleSheetsStreamProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GrapeEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GrapeEndpoint.java
index b9d7e09..3771cf6 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GrapeEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/GrapeEndpoint.java
@@ -63,16 +63,6 @@ public class GrapeEndpoint {
         }
     }
 
-    public static class GrapeConsumer
-            extends
-                GrapeCommon<GrapeConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public GrapeConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class GrapeProducer
             extends
                 GrapeCommon<GrapeProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastAtomicnumberEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastAtomicnumberEndpoint.java
index 12ea597..6cb723a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastAtomicnumberEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastAtomicnumberEndpoint.java
@@ -142,16 +142,6 @@ public class HazelcastAtomicnumberEndpoint {
         }
     }
 
-    public static class HazelcastAtomicnumberConsumer
-            extends
-                HazelcastAtomicnumberCommon<HazelcastAtomicnumberConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public HazelcastAtomicnumberConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class HazelcastAtomicnumberProducer
             extends
                 HazelcastAtomicnumberCommon<HazelcastAtomicnumberProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastInstanceEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastInstanceEndpoint.java
index 973ffe7..833d9ae 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastInstanceEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastInstanceEndpoint.java
@@ -215,16 +215,6 @@ public class HazelcastInstanceEndpoint {
         }
     }
 
-    public static class HazelcastInstanceProducer
-            extends
-                HazelcastInstanceCommon<HazelcastInstanceProducer>
-            implements
-                EndpointDefinition.Producer {
-        public HazelcastInstanceProducer(String path) {
-            super(path);
-        }
-    }
-
     public static enum HazelcastOperation {
         PUT, DELETE, GET, UPDATE, QUERY, GET_ALL, CLEAR, PUT_IF_ABSENT, 
ADD_ALL, REMOVE_ALL, RETAIN_ALL, EVICT, EVICT_ALL, VALUE_COUNT, CONTAINS_KEY, 
CONTAINS_VALUE, GET_KEYS, REMOVE_VALUE, INCREMENT, DECREMENT, SET_VALUE, 
DESTROY, COMPARE_AND_SET, GET_AND_ADD, ADD, OFFER, PEEK, POLL, 
REMAINING_CAPACITY, DRAIN_TO, REMOVE_IF, TAKE, PUBLISH, READ_ONCE_HEAD, 
READ_ONCE_TAIL, CAPACITY;
     }
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastRingbufferEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastRingbufferEndpoint.java
index 30ff81d..dbc24b2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastRingbufferEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HazelcastRingbufferEndpoint.java
@@ -142,16 +142,6 @@ public class HazelcastRingbufferEndpoint {
         }
     }
 
-    public static class HazelcastRingbufferConsumer
-            extends
-                HazelcastRingbufferCommon<HazelcastRingbufferConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public HazelcastRingbufferConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class HazelcastRingbufferProducer
             extends
                 HazelcastRingbufferCommon<HazelcastRingbufferProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HttpEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HttpEndpoint.java
index 31f1eb9..75edd53 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HttpEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/HttpEndpoint.java
@@ -247,16 +247,6 @@ public class HttpEndpoint {
         }
     }
 
-    public static class HttpConsumer
-            extends
-                HttpCommon<HttpConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public HttpConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class HttpProducer
             extends
                 HttpCommon<HttpProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IAMEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IAMEndpoint.java
index 2fa20fc..698a552 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IAMEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IAMEndpoint.java
@@ -69,16 +69,6 @@ public class IAMEndpoint {
         }
     }
 
-    public static class IAMConsumer
-            extends
-                IAMCommon<IAMConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public IAMConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class IAMProducer
             extends
                 IAMCommon<IAMProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IPFSEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IPFSEndpoint.java
index 4c73769..c2f298a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IPFSEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IPFSEndpoint.java
@@ -70,16 +70,6 @@ public class IPFSEndpoint {
         }
     }
 
-    public static class IPFSConsumer
-            extends
-                IPFSCommon<IPFSConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public IPFSConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class IPFSProducer
             extends
                 IPFSCommon<IPFSProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteComputeEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteComputeEndpoint.java
index f2156dc..1bd2cf2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteComputeEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteComputeEndpoint.java
@@ -82,16 +82,6 @@ public class IgniteComputeEndpoint {
         }
     }
 
-    public static class IgniteComputeConsumer
-            extends
-                IgniteComputeCommon<IgniteComputeConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public IgniteComputeConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class IgniteComputeProducer
             extends
                 IgniteComputeCommon<IgniteComputeProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteEventsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteEventsEndpoint.java
index 7de962d..ade31f5 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteEventsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteEventsEndpoint.java
@@ -145,14 +145,4 @@ public class IgniteEventsEndpoint {
             return (IgniteEventsConsumer) this;
         }
     }
-
-    public static class IgniteEventsProducer
-            extends
-                IgniteEventsCommon<IgniteEventsProducer>
-            implements
-                EndpointDefinition.Producer {
-        public IgniteEventsProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteIdGenEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteIdGenEndpoint.java
index a2f2efa..c5b15fc 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteIdGenEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteIdGenEndpoint.java
@@ -80,16 +80,6 @@ public class IgniteIdGenEndpoint {
         }
     }
 
-    public static class IgniteIdGenConsumer
-            extends
-                IgniteIdGenCommon<IgniteIdGenConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public IgniteIdGenConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class IgniteIdGenProducer
             extends
                 IgniteIdGenCommon<IgniteIdGenProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteQueueEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteQueueEndpoint.java
index 0c3a919..3822ed4 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteQueueEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteQueueEndpoint.java
@@ -80,16 +80,6 @@ public class IgniteQueueEndpoint {
         }
     }
 
-    public static class IgniteQueueConsumer
-            extends
-                IgniteQueueCommon<IgniteQueueConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public IgniteQueueConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class IgniteQueueProducer
             extends
                 IgniteQueueCommon<IgniteQueueProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteSetEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteSetEndpoint.java
index 3e16c3b..f58b981 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteSetEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/IgniteSetEndpoint.java
@@ -80,16 +80,6 @@ public class IgniteSetEndpoint {
         }
     }
 
-    public static class IgniteSetConsumer
-            extends
-                IgniteSetCommon<IgniteSetConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public IgniteSetConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class IgniteSetProducer
             extends
                 IgniteSetCommon<IgniteSetProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/InfluxDbEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/InfluxDbEndpoint.java
index a3963bf..257a0a6 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/InfluxDbEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/InfluxDbEndpoint.java
@@ -103,16 +103,6 @@ public class InfluxDbEndpoint {
         }
     }
 
-    public static class InfluxDbConsumer
-            extends
-                InfluxDbCommon<InfluxDbConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public InfluxDbConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class InfluxDbProducer
             extends
                 InfluxDbCommon<InfluxDbProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JMXEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JMXEndpoint.java
index 5e82d69..07475bb 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JMXEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JMXEndpoint.java
@@ -336,14 +336,4 @@ public class JMXEndpoint {
             return (JMXConsumer) this;
         }
     }
-
-    public static class JMXProducer
-            extends
-                JMXCommon<JMXProducer>
-            implements
-                EndpointDefinition.Producer {
-        public JMXProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JdbcEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JdbcEndpoint.java
index 29d5615..c5b05e3 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JdbcEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JdbcEndpoint.java
@@ -186,16 +186,6 @@ public class JdbcEndpoint {
         }
     }
 
-    public static class JdbcConsumer
-            extends
-                JdbcCommon<JdbcConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public JdbcConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class JdbcProducer
             extends
                 JdbcCommon<JdbcProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JingEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JingEndpoint.java
index b5c3d12..02f38ee9 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JingEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JingEndpoint.java
@@ -72,16 +72,6 @@ public class JingEndpoint {
         }
     }
 
-    public static class JingConsumer
-            extends
-                JingCommon<JingConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public JingConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class JingProducer
             extends
                 JingCommon<JingProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JoltEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JoltEndpoint.java
index 6851bac..d28f5f9 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JoltEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JoltEndpoint.java
@@ -100,16 +100,6 @@ public class JoltEndpoint {
         }
     }
 
-    public static class JoltConsumer
-            extends
-                JoltCommon<JoltConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public JoltConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class JoltProducer
             extends
                 JoltCommon<JoltProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JsonValidatorEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JsonValidatorEndpoint.java
index c649f76..3deea69 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JsonValidatorEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/JsonValidatorEndpoint.java
@@ -117,16 +117,6 @@ public class JsonValidatorEndpoint {
         }
     }
 
-    public static class JsonValidatorConsumer
-            extends
-                JsonValidatorCommon<JsonValidatorConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public JsonValidatorConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class JsonValidatorProducer
             extends
                 JsonValidatorCommon<JsonValidatorProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KMSEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KMSEndpoint.java
index ff2e42e..aa90192 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KMSEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KMSEndpoint.java
@@ -69,16 +69,6 @@ public class KMSEndpoint {
         }
     }
 
-    public static class KMSConsumer
-            extends
-                KMSCommon<KMSConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KMSConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KMSProducer
             extends
                 KMSCommon<KMSProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KeystoneEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KeystoneEndpoint.java
index f9a419b..8d824d5 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KeystoneEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KeystoneEndpoint.java
@@ -112,16 +112,6 @@ public class KeystoneEndpoint {
         }
     }
 
-    public static class KeystoneConsumer
-            extends
-                KeystoneCommon<KeystoneConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KeystoneConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KeystoneProducer
             extends
                 KeystoneCommon<KeystoneProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KinesisFirehoseEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KinesisFirehoseEndpoint.java
index ffe33ec..093ed7c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KinesisFirehoseEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KinesisFirehoseEndpoint.java
@@ -109,16 +109,6 @@ public class KinesisFirehoseEndpoint {
         }
     }
 
-    public static class KinesisFirehoseConsumer
-            extends
-                KinesisFirehoseCommon<KinesisFirehoseConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KinesisFirehoseConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KinesisFirehoseProducer
             extends
                 KinesisFirehoseCommon<KinesisFirehoseProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesConfigMapsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesConfigMapsEndpoint.java
index c73e898..4c2378c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesConfigMapsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesConfigMapsEndpoint.java
@@ -198,16 +198,6 @@ public class KubernetesConfigMapsEndpoint {
         }
     }
 
-    public static class KubernetesConfigMapsConsumer
-            extends
-                KubernetesConfigMapsCommon<KubernetesConfigMapsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KubernetesConfigMapsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KubernetesConfigMapsProducer
             extends
                 KubernetesConfigMapsCommon<KubernetesConfigMapsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesClaimsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesClaimsEndpoint.java
index 49e90ff..48b0110 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesClaimsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesClaimsEndpoint.java
@@ -198,16 +198,6 @@ public class KubernetesPersistentVolumesClaimsEndpoint {
         }
     }
 
-    public static class KubernetesPersistentVolumesClaimsConsumer
-            extends
-                
KubernetesPersistentVolumesClaimsCommon<KubernetesPersistentVolumesClaimsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KubernetesPersistentVolumesClaimsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KubernetesPersistentVolumesClaimsProducer
             extends
                 
KubernetesPersistentVolumesClaimsCommon<KubernetesPersistentVolumesClaimsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesEndpoint.java
index a10185c..2ef1267 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesPersistentVolumesEndpoint.java
@@ -198,16 +198,6 @@ public class KubernetesPersistentVolumesEndpoint {
         }
     }
 
-    public static class KubernetesPersistentVolumesConsumer
-            extends
-                
KubernetesPersistentVolumesCommon<KubernetesPersistentVolumesConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KubernetesPersistentVolumesConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KubernetesPersistentVolumesProducer
             extends
                 
KubernetesPersistentVolumesCommon<KubernetesPersistentVolumesProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesResourcesQuotaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesResourcesQuotaEndpoint.java
index 76c27a1..afcb0f8 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesResourcesQuotaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesResourcesQuotaEndpoint.java
@@ -198,16 +198,6 @@ public class KubernetesResourcesQuotaEndpoint {
         }
     }
 
-    public static class KubernetesResourcesQuotaConsumer
-            extends
-                
KubernetesResourcesQuotaCommon<KubernetesResourcesQuotaConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KubernetesResourcesQuotaConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KubernetesResourcesQuotaProducer
             extends
                 
KubernetesResourcesQuotaCommon<KubernetesResourcesQuotaProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesSecretsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesSecretsEndpoint.java
index fa0c17b..08d73fb 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesSecretsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesSecretsEndpoint.java
@@ -198,16 +198,6 @@ public class KubernetesSecretsEndpoint {
         }
     }
 
-    public static class KubernetesSecretsConsumer
-            extends
-                KubernetesSecretsCommon<KubernetesSecretsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KubernetesSecretsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KubernetesSecretsProducer
             extends
                 KubernetesSecretsCommon<KubernetesSecretsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesServiceAccountsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesServiceAccountsEndpoint.java
index ce06437..4c8962c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesServiceAccountsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/KubernetesServiceAccountsEndpoint.java
@@ -198,16 +198,6 @@ public class KubernetesServiceAccountsEndpoint {
         }
     }
 
-    public static class KubernetesServiceAccountsConsumer
-            extends
-                
KubernetesServiceAccountsCommon<KubernetesServiceAccountsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public KubernetesServiceAccountsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class KubernetesServiceAccountsProducer
             extends
                 
KubernetesServiceAccountsCommon<KubernetesServiceAccountsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LambdaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LambdaEndpoint.java
index f3545f1..c73db1c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LambdaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LambdaEndpoint.java
@@ -109,16 +109,6 @@ public class LambdaEndpoint {
         }
     }
 
-    public static class LambdaConsumer
-            extends
-                LambdaCommon<LambdaConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public LambdaConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class LambdaProducer
             extends
                 LambdaCommon<LambdaProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LanguageEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LanguageEndpoint.java
index 63e2311..fe43a59 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LanguageEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LanguageEndpoint.java
@@ -113,16 +113,6 @@ public class LanguageEndpoint {
         }
     }
 
-    public static class LanguageConsumer
-            extends
-                LanguageCommon<LanguageConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public LanguageConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class LanguageProducer
             extends
                 LanguageCommon<LanguageProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdapEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdapEndpoint.java
index 9659194..7b627de 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdapEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdapEndpoint.java
@@ -105,16 +105,6 @@ public class LdapEndpoint {
         }
     }
 
-    public static class LdapConsumer
-            extends
-                LdapCommon<LdapConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public LdapConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class LdapProducer
             extends
                 LdapCommon<LdapProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdifEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdifEndpoint.java
index d1a8c27..4f05f84 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdifEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LdifEndpoint.java
@@ -65,16 +65,6 @@ public class LdifEndpoint {
         }
     }
 
-    public static class LdifConsumer
-            extends
-                LdifCommon<LdifConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public LdifConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class LdifProducer
             extends
                 LdifCommon<LdifProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LogEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LogEndpoint.java
index 12a8688..1e3ca49 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LogEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LogEndpoint.java
@@ -265,16 +265,6 @@ public class LogEndpoint {
         }
     }
 
-    public static class LogConsumer
-            extends
-                LogCommon<LogConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public LogConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class LogProducer
             extends
                 LogCommon<LogProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LuceneEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LuceneEndpoint.java
index f7c5be1..f79e581 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LuceneEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LuceneEndpoint.java
@@ -108,16 +108,6 @@ public class LuceneEndpoint {
         }
     }
 
-    public static class LuceneConsumer
-            extends
-                LuceneCommon<LuceneConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public LuceneConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class LuceneProducer
             extends
                 LuceneCommon<LuceneProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LumberjackEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LumberjackEndpoint.java
index 29039b8..b83a57a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LumberjackEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/LumberjackEndpoint.java
@@ -124,14 +124,4 @@ public class LumberjackEndpoint {
             return (LumberjackConsumer) this;
         }
     }
-
-    public static class LumberjackProducer
-            extends
-                LumberjackCommon<LumberjackProducer>
-            implements
-                EndpointDefinition.Producer {
-        public LumberjackProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MQEndpoint.java 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MQEndpoint.java
index 42510ee..91b9398 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MQEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MQEndpoint.java
@@ -69,16 +69,6 @@ public class MQEndpoint {
         }
     }
 
-    public static class MQConsumer
-            extends
-                MQCommon<MQConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MQConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MQProducer
             extends
                 MQCommon<MQProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MSKEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MSKEndpoint.java
index 655dccf..12c6377 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MSKEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MSKEndpoint.java
@@ -69,16 +69,6 @@ public class MSKEndpoint {
         }
     }
 
-    public static class MSKConsumer
-            extends
-                MSKCommon<MSKConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MSKConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MSKProducer
             extends
                 MSKCommon<MSKProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MasterEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MasterEndpoint.java
index 3f49da9..fc07625 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MasterEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MasterEndpoint.java
@@ -114,14 +114,4 @@ public class MasterEndpoint {
             return (MasterConsumer) this;
         }
     }
-
-    public static class MasterProducer
-            extends
-                MasterCommon<MasterProducer>
-            implements
-                EndpointDefinition.Producer {
-        public MasterProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MetricsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MetricsEndpoint.java
index 39926fe..d168509 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MetricsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MetricsEndpoint.java
@@ -117,16 +117,6 @@ public class MetricsEndpoint {
         }
     }
 
-    public static class MetricsConsumer
-            extends
-                MetricsCommon<MetricsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MetricsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MetricsProducer
             extends
                 MetricsCommon<MetricsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MicrometerEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MicrometerEndpoint.java
index 5988d9d..d2a0ae2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MicrometerEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MicrometerEndpoint.java
@@ -110,16 +110,6 @@ public class MicrometerEndpoint {
         }
     }
 
-    public static class MicrometerConsumer
-            extends
-                MicrometerCommon<MicrometerConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MicrometerConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MicrometerProducer
             extends
                 MicrometerCommon<MicrometerProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MockEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MockEndpoint.java
index 8adea1c..2ac2c02 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MockEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MockEndpoint.java
@@ -62,16 +62,6 @@ public class MockEndpoint {
         }
     }
 
-    public static class MockConsumer
-            extends
-                MockCommon<MockConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MockConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MockProducer
             extends
                 MockCommon<MockProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MsvEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MsvEndpoint.java
index d49d0a1..bee9eff 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MsvEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MsvEndpoint.java
@@ -145,16 +145,6 @@ public class MsvEndpoint {
         }
     }
 
-    public static class MsvConsumer
-            extends
-                MsvCommon<MsvConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MsvConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MsvProducer
             extends
                 MsvCommon<MsvProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MustacheEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MustacheEndpoint.java
index 26a3214..5b1bc28 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MustacheEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MustacheEndpoint.java
@@ -98,16 +98,6 @@ public class MustacheEndpoint {
         }
     }
 
-    public static class MustacheConsumer
-            extends
-                MustacheCommon<MustacheConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MustacheConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MustacheProducer
             extends
                 MustacheCommon<MustacheProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MvelEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MvelEndpoint.java
index 9e1c038..d7117c4 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MvelEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MvelEndpoint.java
@@ -82,16 +82,6 @@ public class MvelEndpoint {
         }
     }
 
-    public static class MvelConsumer
-            extends
-                MvelCommon<MvelConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MvelConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MvelProducer
             extends
                 MvelCommon<MvelProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MyBatisBeanEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MyBatisBeanEndpoint.java
index 98f45a0..d2397d5 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MyBatisBeanEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/MyBatisBeanEndpoint.java
@@ -72,16 +72,6 @@ public class MyBatisBeanEndpoint {
         }
     }
 
-    public static class MyBatisBeanConsumer
-            extends
-                MyBatisBeanCommon<MyBatisBeanConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public MyBatisBeanConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class MyBatisBeanProducer
             extends
                 MyBatisBeanCommon<MyBatisBeanProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NagiosEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NagiosEndpoint.java
index 4066f52..92fdc5a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NagiosEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NagiosEndpoint.java
@@ -118,16 +118,6 @@ public class NagiosEndpoint {
         }
     }
 
-    public static class NagiosConsumer
-            extends
-                NagiosCommon<NagiosConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public NagiosConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class NagiosProducer
             extends
                 NagiosCommon<NagiosProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NetWeaverEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NetWeaverEndpoint.java
index 05d92b5..fc22b14 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NetWeaverEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NetWeaverEndpoint.java
@@ -102,16 +102,6 @@ public class NetWeaverEndpoint {
         }
     }
 
-    public static class NetWeaverConsumer
-            extends
-                NetWeaverCommon<NetWeaverConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public NetWeaverConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class NetWeaverProducer
             extends
                 NetWeaverCommon<NetWeaverProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NeutronEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NeutronEndpoint.java
index ca2f9bf..477f2e1 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NeutronEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NeutronEndpoint.java
@@ -119,16 +119,6 @@ public class NeutronEndpoint {
         }
     }
 
-    public static class NeutronConsumer
-            extends
-                NeutronCommon<NeutronConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public NeutronConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class NeutronProducer
             extends
                 NeutronCommon<NeutronProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NovaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NovaEndpoint.java
index 56eb7c8..5322832 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NovaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/NovaEndpoint.java
@@ -119,16 +119,6 @@ public class NovaEndpoint {
         }
     }
 
-    public static class NovaConsumer
-            extends
-                NovaCommon<NovaConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public NovaConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class NovaProducer
             extends
                 NovaCommon<NovaProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildConfigsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildConfigsEndpoint.java
index 301bf61..b51f9c2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildConfigsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildConfigsEndpoint.java
@@ -198,16 +198,6 @@ public class OpenshiftBuildConfigsEndpoint {
         }
     }
 
-    public static class OpenshiftBuildConfigsConsumer
-            extends
-                OpenshiftBuildConfigsCommon<OpenshiftBuildConfigsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public OpenshiftBuildConfigsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class OpenshiftBuildConfigsProducer
             extends
                 OpenshiftBuildConfigsCommon<OpenshiftBuildConfigsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildsEndpoint.java
index 9469ce9..149675f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/OpenshiftBuildsEndpoint.java
@@ -198,16 +198,6 @@ public class OpenshiftBuildsEndpoint {
         }
     }
 
-    public static class OpenshiftBuildsConsumer
-            extends
-                OpenshiftBuildsCommon<OpenshiftBuildsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public OpenshiftBuildsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class OpenshiftBuildsProducer
             extends
                 OpenshiftBuildsCommon<OpenshiftBuildsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PaxLoggingEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PaxLoggingEndpoint.java
index 5dc9370..2364a3e 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PaxLoggingEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PaxLoggingEndpoint.java
@@ -109,14 +109,4 @@ public class PaxLoggingEndpoint {
             return (PaxLoggingConsumer) this;
         }
     }
-
-    public static class PaxLoggingProducer
-            extends
-                PaxLoggingCommon<PaxLoggingProducer>
-            implements
-                EndpointDefinition.Producer {
-        public PaxLoggingProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PdfEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PdfEndpoint.java
index 221dc87..d967eee 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PdfEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PdfEndpoint.java
@@ -128,16 +128,6 @@ public class PdfEndpoint {
         }
     }
 
-    public static class PdfConsumer
-            extends
-                PdfCommon<PdfConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public PdfConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class PdfProducer
             extends
                 PdfCommon<PdfProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PrinterEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PrinterEndpoint.java
index 235df2c..b3129e2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PrinterEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/PrinterEndpoint.java
@@ -156,16 +156,6 @@ public class PrinterEndpoint {
         }
     }
 
-    public static class PrinterConsumer
-            extends
-                PrinterCommon<PrinterConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public PrinterConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class PrinterProducer
             extends
                 PrinterCommon<PrinterProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/QuartzEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/QuartzEndpoint.java
index 5d00f84..3a6c490 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/QuartzEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/QuartzEndpoint.java
@@ -245,14 +245,4 @@ public class QuartzEndpoint {
             return (QuartzConsumer) this;
         }
     }
-
-    public static class QuartzProducer
-            extends
-                QuartzCommon<QuartzProducer>
-            implements
-                EndpointDefinition.Producer {
-        public QuartzProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestApiEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestApiEndpoint.java
index 900ca09..96046e0 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestApiEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestApiEndpoint.java
@@ -136,14 +136,4 @@ public class RestApiEndpoint {
             return (RestApiConsumer) this;
         }
     }
-
-    public static class RestApiProducer
-            extends
-                RestApiCommon<RestApiProducer>
-            implements
-                EndpointDefinition.Producer {
-        public RestApiProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestSwaggerEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestSwaggerEndpoint.java
index 1004d47..093d200 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestSwaggerEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RestSwaggerEndpoint.java
@@ -55,16 +55,6 @@ public class RestSwaggerEndpoint {
         }
     }
 
-    public static class RestSwaggerConsumer
-            extends
-                RestSwaggerCommon<RestSwaggerConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public RestSwaggerConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class RestSwaggerProducer
             extends
                 RestSwaggerCommon<RestSwaggerProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RssEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RssEndpoint.java
index 3108afe..a42c11f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RssEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/RssEndpoint.java
@@ -320,14 +320,4 @@ public class RssEndpoint {
             return (RssConsumer) this;
         }
     }
-
-    public static class RssProducer
-            extends
-                RssCommon<RssProducer>
-            implements
-                EndpointDefinition.Producer {
-        public RssProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SagaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SagaEndpoint.java
index b950991..4552bd2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SagaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SagaEndpoint.java
@@ -63,16 +63,6 @@ public class SagaEndpoint {
         }
     }
 
-    public static class SagaConsumer
-            extends
-                SagaCommon<SagaConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SagaConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SagaProducer
             extends
                 SagaCommon<SagaProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchedulerEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchedulerEndpoint.java
index 60eafc3..20b0717 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchedulerEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchedulerEndpoint.java
@@ -263,14 +263,4 @@ public class SchedulerEndpoint {
             return (SchedulerConsumer) this;
         }
     }
-
-    public static class SchedulerProducer
-            extends
-                SchedulerCommon<SchedulerProducer>
-            implements
-                EndpointDefinition.Producer {
-        public SchedulerProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchematronEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchematronEndpoint.java
index b0e64e8..34bb55b 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchematronEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SchematronEndpoint.java
@@ -86,16 +86,6 @@ public class SchematronEndpoint {
         }
     }
 
-    public static class SchematronConsumer
-            extends
-                SchematronCommon<SchematronConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SchematronConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SchematronProducer
             extends
                 SchematronCommon<SchematronProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ScpEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ScpEndpoint.java
index a03e85e..bd18e60 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ScpEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ScpEndpoint.java
@@ -236,16 +236,6 @@ public class ScpEndpoint {
         }
     }
 
-    public static class ScpConsumer
-            extends
-                ScpCommon<ScpConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ScpConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ScpProducer
             extends
                 ScpCommon<ScpProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SdbEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SdbEndpoint.java
index 56f4af8..cc44e54 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SdbEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SdbEndpoint.java
@@ -133,16 +133,6 @@ public class SdbEndpoint {
         }
     }
 
-    public static class SdbConsumer
-            extends
-                SdbCommon<SdbConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SdbConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SdbProducer
             extends
                 SdbCommon<SdbProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceEndpoint.java
index 8b5b224..aa52531 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceEndpoint.java
@@ -107,14 +107,4 @@ public class ServiceEndpoint {
             return (ServiceConsumer) this;
         }
     }
-
-    public static class ServiceProducer
-            extends
-                ServiceCommon<ServiceProducer>
-            implements
-                EndpointDefinition.Producer {
-        public ServiceProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceNowEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceNowEndpoint.java
index e2464f8..3e8c193 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceNowEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServiceNowEndpoint.java
@@ -422,16 +422,6 @@ public class ServiceNowEndpoint {
         }
     }
 
-    public static class ServiceNowConsumer
-            extends
-                ServiceNowCommon<ServiceNowConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ServiceNowConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ServiceNowProducer
             extends
                 ServiceNowCommon<ServiceNowProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServletEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServletEndpoint.java
index d472d86..2dbee0d 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServletEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ServletEndpoint.java
@@ -290,14 +290,4 @@ public class ServletEndpoint {
             return (ServletConsumer) this;
         }
     }
-
-    public static class ServletProducer
-            extends
-                ServletCommon<ServletProducer>
-            implements
-                EndpointDefinition.Producer {
-        public ServletProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SesEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SesEndpoint.java
index e2dd3a6..fada839 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SesEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SesEndpoint.java
@@ -143,16 +143,6 @@ public class SesEndpoint {
         }
     }
 
-    public static class SesConsumer
-            extends
-                SesCommon<SesConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SesConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SesProducer
             extends
                 SesCommon<SesProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SjmsBatchEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SjmsBatchEndpoint.java
index f5b18a5..13661c6 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SjmsBatchEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SjmsBatchEndpoint.java
@@ -317,14 +317,4 @@ public class SjmsBatchEndpoint {
             return (SjmsBatchConsumer) this;
         }
     }
-
-    public static class SjmsBatchProducer
-            extends
-                SjmsBatchCommon<SjmsBatchProducer>
-            implements
-                EndpointDefinition.Producer {
-        public SjmsBatchProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnmpEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnmpEndpoint.java
index 29ba1aa..52d252c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnmpEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnmpEndpoint.java
@@ -410,16 +410,6 @@ public class SnmpEndpoint {
         }
     }
 
-    public static class SnmpProducer
-            extends
-                SnmpCommon<SnmpProducer>
-            implements
-                EndpointDefinition.Producer {
-        public SnmpProducer(String path) {
-            super(path);
-        }
-    }
-
     public static enum SnmpActionType {
         TRAP, POLL, GET_NEXT;
     }
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnsEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnsEndpoint.java
index c081246..5bab67f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnsEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SnsEndpoint.java
@@ -186,16 +186,6 @@ public class SnsEndpoint {
         }
     }
 
-    public static class SnsConsumer
-            extends
-                SnsCommon<SnsConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SnsConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SnsProducer
             extends
                 SnsCommon<SnsProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SolrEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SolrEndpoint.java
index 45ef9ef..104a08f 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SolrEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SolrEndpoint.java
@@ -160,16 +160,6 @@ public class SolrEndpoint {
         }
     }
 
-    public static class SolrConsumer
-            extends
-                SolrCommon<SolrConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SolrConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SolrProducer
             extends
                 SolrCommon<SolrProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SparkEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SparkEndpoint.java
index 865d674..9926c90 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SparkEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SparkEndpoint.java
@@ -190,14 +190,4 @@ public class SparkEndpoint {
             return (SparkConsumer) this;
         }
     }
-
-    public static class SparkProducer
-            extends
-                SparkCommon<SparkProducer>
-            implements
-                EndpointDefinition.Producer {
-        public SparkProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringBatchEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringBatchEndpoint.java
index f007fd1..3a505c7 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringBatchEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringBatchEndpoint.java
@@ -87,16 +87,6 @@ public class SpringBatchEndpoint {
         }
     }
 
-    public static class SpringBatchConsumer
-            extends
-                SpringBatchCommon<SpringBatchConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SpringBatchConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SpringBatchProducer
             extends
                 SpringBatchCommon<SpringBatchProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringLdapEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringLdapEndpoint.java
index ab6cffe..d256aaf 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringLdapEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SpringLdapEndpoint.java
@@ -79,16 +79,6 @@ public class SpringLdapEndpoint {
         }
     }
 
-    public static class SpringLdapConsumer
-            extends
-                SpringLdapCommon<SpringLdapConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SpringLdapConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SpringLdapProducer
             extends
                 SpringLdapCommon<SpringLdapProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SqlStoredEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SqlStoredEndpoint.java
index 8ca3599..a63ea60 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SqlStoredEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SqlStoredEndpoint.java
@@ -115,16 +115,6 @@ public class SqlStoredEndpoint {
         }
     }
 
-    public static class SqlStoredConsumer
-            extends
-                SqlStoredCommon<SqlStoredConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SqlStoredConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SqlStoredProducer
             extends
                 SqlStoredCommon<SqlStoredProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StAXEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StAXEndpoint.java
index dd2f7fc..6c8c7f6 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StAXEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StAXEndpoint.java
@@ -63,16 +63,6 @@ public class StAXEndpoint {
         }
     }
 
-    public static class StAXConsumer
-            extends
-                StAXCommon<StAXConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public StAXConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class StAXProducer
             extends
                 StAXCommon<StAXProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StringTemplateEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StringTemplateEndpoint.java
index 6e1b51c..83b848b 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StringTemplateEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/StringTemplateEndpoint.java
@@ -88,16 +88,6 @@ public class StringTemplateEndpoint {
         }
     }
 
-    public static class StringTemplateConsumer
-            extends
-                StringTemplateCommon<StringTemplateConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public StringTemplateConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class StringTemplateProducer
             extends
                 StringTemplateCommon<StringTemplateProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SwiftEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SwiftEndpoint.java
index 43a9190..34ac344 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SwiftEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/SwiftEndpoint.java
@@ -119,16 +119,6 @@ public class SwiftEndpoint {
         }
     }
 
-    public static class SwiftConsumer
-            extends
-                SwiftCommon<SwiftConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public SwiftConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class SwiftProducer
             extends
                 SwiftCommon<SwiftProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TikaEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TikaEndpoint.java
index 831ebbf..20c95d8 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TikaEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TikaEndpoint.java
@@ -99,16 +99,6 @@ public class TikaEndpoint {
         }
     }
 
-    public static class TikaConsumer
-            extends
-                TikaCommon<TikaConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public TikaConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class TikaProducer
             extends
                 TikaCommon<TikaProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TimerEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TimerEndpoint.java
index 2020ee4..034028a 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TimerEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TimerEndpoint.java
@@ -179,14 +179,4 @@ public class TimerEndpoint {
             return (TimerConsumer) this;
         }
     }
-
-    public static class TimerProducer
-            extends
-                TimerCommon<TimerProducer>
-            implements
-                EndpointDefinition.Producer {
-        public TimerProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TwitterStreamingEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TwitterStreamingEndpoint.java
index 5494d1f..649d694 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TwitterStreamingEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/TwitterStreamingEndpoint.java
@@ -466,16 +466,6 @@ public class TwitterStreamingEndpoint {
         }
     }
 
-    public static class TwitterStreamingProducer
-            extends
-                TwitterStreamingCommon<TwitterStreamingProducer>
-            implements
-                EndpointDefinition.Producer {
-        public TwitterStreamingProducer(String path) {
-            super(path);
-        }
-    }
-
     public static enum StreamingType {
         SAMPLE, FILTER, USER, UNKNOWN;
     }
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ValidatorEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ValidatorEndpoint.java
index d73ba9a..7c08de2 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ValidatorEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ValidatorEndpoint.java
@@ -145,16 +145,6 @@ public class ValidatorEndpoint {
         }
     }
 
-    public static class ValidatorConsumer
-            extends
-                ValidatorCommon<ValidatorConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public ValidatorConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class ValidatorProducer
             extends
                 ValidatorCommon<ValidatorProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/VelocityEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/VelocityEndpoint.java
index c3727d4..e29b266 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/VelocityEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/VelocityEndpoint.java
@@ -98,16 +98,6 @@ public class VelocityEndpoint {
         }
     }
 
-    public static class VelocityConsumer
-            extends
-                VelocityCommon<VelocityConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public VelocityConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class VelocityProducer
             extends
                 VelocityCommon<VelocityProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/WebhookEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/WebhookEndpoint.java
index 845641b..57b212e 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/WebhookEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/WebhookEndpoint.java
@@ -150,14 +150,4 @@ public class WebhookEndpoint {
             return (WebhookConsumer) this;
         }
     }
-
-    public static class WebhookProducer
-            extends
-                WebhookCommon<WebhookProducer>
-            implements
-                EndpointDefinition.Producer {
-        public WebhookProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XChangeEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XChangeEndpoint.java
index bd269a2..d208892 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XChangeEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XChangeEndpoint.java
@@ -95,16 +95,6 @@ public class XChangeEndpoint {
         }
     }
 
-    public static class XChangeConsumer
-            extends
-                XChangeCommon<XChangeConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public XChangeConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class XChangeProducer
             extends
                 XChangeCommon<XChangeProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XmlSignatureEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XmlSignatureEndpoint.java
index 4443aa9..cfe99dc 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XmlSignatureEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XmlSignatureEndpoint.java
@@ -483,16 +483,6 @@ public class XmlSignatureEndpoint {
         }
     }
 
-    public static class XmlSignatureConsumer
-            extends
-                XmlSignatureCommon<XmlSignatureConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public XmlSignatureConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class XmlSignatureProducer
             extends
                 XmlSignatureCommon<XmlSignatureProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XsltEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XsltEndpoint.java
index 5add314..d0cd26c 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XsltEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/XsltEndpoint.java
@@ -212,16 +212,6 @@ public class XsltEndpoint {
         }
     }
 
-    public static class XsltConsumer
-            extends
-                XsltCommon<XsltConsumer>
-            implements
-                EndpointDefinition.Consumer {
-        public XsltConsumer(String path) {
-            super(path);
-        }
-    }
-
     public static class XsltProducer
             extends
                 XsltCommon<XsltProducer>
diff --git 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ZooKeeperMasterEndpoint.java
 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ZooKeeperMasterEndpoint.java
index 3b7aae3..419f7da 100644
--- 
a/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ZooKeeperMasterEndpoint.java
+++ 
b/core/camel-core/src/main/java/org/apache/camel/model/endpoint/ZooKeeperMasterEndpoint.java
@@ -117,14 +117,4 @@ public class ZooKeeperMasterEndpoint {
             return (ZooKeeperMasterConsumer) this;
         }
     }
-
-    public static class ZooKeeperMasterProducer
-            extends
-                ZooKeeperMasterCommon<ZooKeeperMasterProducer>
-            implements
-                EndpointDefinition.Producer {
-        public ZooKeeperMasterProducer(String path) {
-            super(path);
-        }
-    }
 }
\ No newline at end of file
diff --git 
a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointDslMojo.java
 
b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointDslMojo.java
index 8971fdc..deec1dc 100644
--- 
a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointDslMojo.java
+++ 
b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointDslMojo.java
@@ -50,6 +50,7 @@ import 
org.apache.camel.maven.packaging.srcgen.GenericType.BoundType;
 import org.apache.camel.maven.packaging.srcgen.JavaClass;
 import org.apache.camel.maven.packaging.srcgen.Method;
 import org.apache.camel.maven.packaging.srcgen.Property;
+import org.apache.camel.spi.UriEndpoint;
 import org.apache.camel.spi.UriParam;
 import org.apache.camel.spi.UriParams;
 import org.apache.camel.spi.UriPath;
@@ -225,25 +226,35 @@ public class EndpointDslMojo extends AbstractMojo {
                 .setBody("super(\"" + model.getScheme() + "\", path);");
         generateDummyClass(commonClass.getCanonicalName());
 
-        JavaClass consumerClass = 
javaClass.addNestedType().setPublic().setStatic(true);
-        consumerClass.setName(name.replace("Endpoint", "Consumer"));
-        consumerClass.extendSuperType(name.replace("Endpoint", "Common") + "<" 
+ name.replace("Endpoint", "Consumer") + ">");
-        consumerClass.implementInterface("EndpointDefinition.Consumer");
-        consumerClass.addMethod().setConstructor(true).setPublic()
-                .setName(name.replace("Endpoint", "Consumer"))
-                .addParameter(String.class, "path")
-                .setBody("super(path);");
-        generateDummyClass(consumerClass.getCanonicalName());
-
-        JavaClass producerClass = 
javaClass.addNestedType().setPublic().setStatic(true);
-        producerClass.setName(name.replace("Endpoint", "Producer"));
-        producerClass.extendSuperType(name.replace("Endpoint", "Common") + "<" 
+ name.replace("Endpoint", "Producer") + ">");
-        producerClass.implementInterface("EndpointDefinition.Producer");
-        producerClass.addMethod().setConstructor(true).setPublic()
-                .setName(name.replace("Endpoint", "Producer"))
-                .addParameter(String.class, "path")
-                .setBody("super(path);");
-        generateDummyClass(producerClass.getCanonicalName());
+        JavaClass consumerClass;
+        if (realEndpointClass.getAnnotation(UriEndpoint.class).producerOnly()) 
{
+            consumerClass = null;
+        } else {
+            consumerClass = 
javaClass.addNestedType().setPublic().setStatic(true);
+            consumerClass.setName(name.replace("Endpoint", "Consumer"));
+            consumerClass.extendSuperType(name.replace("Endpoint", "Common") + 
"<" + name.replace("Endpoint", "Consumer") + ">");
+            consumerClass.implementInterface("EndpointDefinition.Consumer");
+            consumerClass.addMethod().setConstructor(true).setPublic()
+                    .setName(name.replace("Endpoint", "Consumer"))
+                    .addParameter(String.class, "path")
+                    .setBody("super(path);");
+            generateDummyClass(consumerClass.getCanonicalName());
+        }
+
+        JavaClass producerClass;
+        if (realEndpointClass.getAnnotation(UriEndpoint.class).consumerOnly()) 
{
+            producerClass = null;
+        } else {
+            producerClass = 
javaClass.addNestedType().setPublic().setStatic(true);
+            producerClass.setName(name.replace("Endpoint", "Producer"));
+            producerClass.extendSuperType(name.replace("Endpoint", "Common") + 
"<" + name.replace("Endpoint", "Producer") + ">");
+            producerClass.implementInterface("EndpointDefinition.Producer");
+            producerClass.addMethod().setConstructor(true).setPublic()
+                    .setName(name.replace("Endpoint", "Producer"))
+                    .addParameter(String.class, "path")
+                    .setBody("super(path);");
+            generateDummyClass(producerClass.getCanonicalName());
+        }
 
         generateDummyClass(packageName + ".T");
 

Reply via email to