Iggy Offset Consumer

Author: Croway

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/iggy.json

@@ -30,6 +30,8 @@ private org.apache.camel.component.iggy.IggyConfiguration getOrCreateConfigurati
     public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
         IggyComponent target = (IggyComponent) obj;
         switch (ignoreCase ? name.toLowerCase() : name) {
+        case "autocommit":
+        case "autoCommit": getOrCreateConfiguration(target).setAutoCommit(property(camelContext, boolean.class, value)); return true;
         case "autocreatestream":
         case "autoCreateStream": getOrCreateConfiguration(target).setAutoCreateStream(property(camelContext, boolean.class, value)); return true;
         case "autocreatetopic":
@@ -69,6 +71,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
         case "replicationFactor": getOrCreateConfiguration(target).setReplicationFactor(property(camelContext, java.lang.Short.class, value)); return true;
         case "shutdowntimeout":
         case "shutdownTimeout": getOrCreateConfiguration(target).setShutdownTimeout(property(camelContext, int.class, value)); return true;
+        case "startingoffset":
+        case "startingOffset": getOrCreateConfiguration(target).setStartingOffset(property(camelContext, java.lang.Long.class, value)); return true;
         case "streamid":
         case "streamId": getOrCreateConfiguration(target).setStreamId(property(camelContext, java.lang.Long.class, value)); return true;
         case "streamname":
@@ -81,6 +85,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
     @Override
     public Class<?> getOptionType(String name, boolean ignoreCase) {
         switch (ignoreCase ? name.toLowerCase() : name) {
+        case "autocommit":
+        case "autoCommit": return boolean.class;
         case "autocreatestream":
         case "autoCreateStream": return boolean.class;
         case "autocreatetopic":
@@ -120,6 +126,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
         case "replicationFactor": return java.lang.Short.class;
         case "shutdowntimeout":
         case "shutdownTimeout": return int.class;
+        case "startingoffset":
+        case "startingOffset": return java.lang.Long.class;
         case "streamid":
         case "streamId": return java.lang.Long.class;
         case "streamname":
@@ -133,6 +141,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
     public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         IggyComponent target = (IggyComponent) obj;
         switch (ignoreCase ? name.toLowerCase() : name) {
+        case "autocommit":
+        case "autoCommit": return getOrCreateConfiguration(target).isAutoCommit();
         case "autocreatestream":
         case "autoCreateStream": return getOrCreateConfiguration(target).isAutoCreateStream();
         case "autocreatetopic":
@@ -172,6 +182,8 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         case "replicationFactor": return getOrCreateConfiguration(target).getReplicationFactor();
         case "shutdowntimeout":
         case "shutdownTimeout": return getOrCreateConfiguration(target).getShutdownTimeout();
+        case "startingoffset":
+        case "startingOffset": return getOrCreateConfiguration(target).getStartingOffset();
         case "streamid":
         case "streamId": return getOrCreateConfiguration(target).getStreamId();
         case "streamname":

components/camel-iggy/src/generated/java/org/apache/camel/component/iggy/IggyComponentConfigurer.java

@@ -23,6 +23,8 @@ public class IggyEndpointConfigurer extends PropertyConfigurerSupport implements
     public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
         IggyEndpoint target = (IggyEndpoint) obj;
         switch (ignoreCase ? name.toLowerCase() : name) {
+        case "autocommit":
+        case "autoCommit": target.getConfiguration().setAutoCommit(property(camelContext, boolean.class, value)); return true;
         case "autocreatestream":
         case "autoCreateStream": target.getConfiguration().setAutoCreateStream(property(camelContext, boolean.class, value)); return true;
         case "autocreatetopic":
@@ -63,6 +65,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
         case "replicationFactor": target.getConfiguration().setReplicationFactor(property(camelContext, java.lang.Short.class, value)); return true;
         case "shutdowntimeout":
         case "shutdownTimeout": target.getConfiguration().setShutdownTimeout(property(camelContext, int.class, value)); return true;
+        case "startingoffset":
+        case "startingOffset": target.getConfiguration().setStartingOffset(property(camelContext, java.lang.Long.class, value)); return true;
         case "streamid":
         case "streamId": target.getConfiguration().setStreamId(property(camelContext, java.lang.Long.class, value)); return true;
         case "streamname":
@@ -75,6 +79,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
     @Override
     public Class<?> getOptionType(String name, boolean ignoreCase) {
         switch (ignoreCase ? name.toLowerCase() : name) {
+        case "autocommit":
+        case "autoCommit": return boolean.class;
         case "autocreatestream":
         case "autoCreateStream": return boolean.class;
         case "autocreatetopic":
@@ -115,6 +121,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
         case "replicationFactor": return java.lang.Short.class;
         case "shutdowntimeout":
         case "shutdownTimeout": return int.class;
+        case "startingoffset":
+        case "startingOffset": return java.lang.Long.class;
         case "streamid":
         case "streamId": return java.lang.Long.class;
         case "streamname":
@@ -128,6 +136,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
     public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         IggyEndpoint target = (IggyEndpoint) obj;
         switch (ignoreCase ? name.toLowerCase() : name) {
+        case "autocommit":
+        case "autoCommit": return target.getConfiguration().isAutoCommit();
         case "autocreatestream":
         case "autoCreateStream": return target.getConfiguration().isAutoCreateStream();
         case "autocreatetopic":
@@ -168,6 +178,8 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         case "replicationFactor": return target.getConfiguration().getReplicationFactor();
         case "shutdowntimeout":
         case "shutdownTimeout": return target.getConfiguration().getShutdownTimeout();
+        case "startingoffset":
+        case "startingOffset": return target.getConfiguration().getStartingOffset();
         case "streamid":
         case "streamId": return target.getConfiguration().getStreamId();
         case "streamname":

components/camel-iggy/src/generated/java/org/apache/camel/component/iggy/IggyEndpointConfigurer.java

@@ -23,7 +23,8 @@ public class IggyEndpointUriFactory extends org.apache.camel.support.component.E
     private static final Set<String> SECRET_PROPERTY_NAMES;
     private static final Set<String> MULTI_VALUE_PREFIXES;
     static {
-        Set<String> props = new HashSet<>(26);
+        Set<String> props = new HashSet<>(28);
+        props.add("autoCommit");
         props.add("autoCreateStream");
         props.add("autoCreateTopic");
         props.add("bridgeErrorHandler");
@@ -46,6 +47,7 @@ public class IggyEndpointUriFactory extends org.apache.camel.support.component.E
         props.add("port");
         props.add("replicationFactor");
         props.add("shutdownTimeout");
+        props.add("startingOffset");
         props.add("streamId");
         props.add("streamName");
         props.add("topicName");