Skip to content

CAMEL-23149: Add TLS configuration options to camel-iggy #21977

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gnodet merged 3 commits into from
Mar 16, 2026
Merged

CAMEL-23149: Add TLS configuration options to camel-iggy #21977

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
70b6b95
CAMEL-23149: Add TLS configuration options to camel-iggy
gnodet Mar 13, 2026
b54f143
CAMEL-23149: Add SSLContextParameters support to camel-iggy
gnodet Mar 13, 2026
d7274f3
Regenerate DSL files after adding SSL support
gnodet Mar 13, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 9 additions & 2 deletions catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/iggy.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,11 @@
"lazyStartProducer": { "index": 23, "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing." },
"partitioning": { "index": 24, "kind": "property", "displayName": "Partitioning", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.iggy.message.Partitioning", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "balanced", "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Partitioning strategy for message distribution" },
"autowiredEnabled": { "index": 25, "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc." },
"username": { "index": 26, "kind": "property", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Iggy username" }
"sslContextParameters": { "index": 26, "kind": "property", "displayName": "Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "SSL configuration using an org.apache.camel.support.jsse.SSLContextParameters instance. This takes precedence over tlsEnabled and tlsCertificatePath when configured." },
"tlsCertificatePath": { "index": 27, "kind": "property", "displayName": "Tls Certificate Path", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Path to the TLS certificate file for the connection to the Iggy server" },
"tlsEnabled": { "index": 28, "kind": "property", "displayName": "Tls Enabled", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Whether to enable TLS for the connection to the Iggy server" },
"useGlobalSslContextParameters": { "index": 29, "kind": "property", "displayName": "Use Global Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable usage of global SSL context parameters." },
"username": { "index": 30, "kind": "property", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Iggy username" }
},
"properties": {
"topicName": { "index": 0, "kind": "path", "displayName": "Topic Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Name of the topic" },
Expand Down Expand Up @@ -80,6 +84,9 @@
"exchangePattern": { "index": 24, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "enum", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
"partitioning": { "index": 25, "kind": "parameter", "displayName": "Partitioning", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.iggy.message.Partitioning", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "balanced", "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Partitioning strategy for message distribution" },
"lazyStartProducer": { "index": 26, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing." },
"username": { "index": 27, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Iggy username" }
"sslContextParameters": { "index": 27, "kind": "parameter", "displayName": "Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "SSL configuration using an org.apache.camel.support.jsse.SSLContextParameters instance. This takes precedence over tlsEnabled and tlsCertificatePath when configured." },
"tlsCertificatePath": { "index": 28, "kind": "parameter", "displayName": "Tls Certificate Path", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Path to the TLS certificate file for the connection to the Iggy server" },
"tlsEnabled": { "index": 29, "kind": "parameter", "displayName": "Tls Enabled", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Whether to enable TLS for the connection to the Iggy server" },
"username": { "index": 30, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.iggy.IggyConfiguration", "configurationField": "configuration", "description": "Iggy username" }
}
}
24 changes: 24 additions & 0 deletions ...amel-iggy/src/generated/java/org/apache/camel/component/iggy/IggyComponentConfigurer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -71,12 +71,20 @@ 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 "sslcontextparameters":
case "sslContextParameters": getOrCreateConfiguration(target).setSslContextParameters(property(camelContext, org.apache.camel.support.jsse.SSLContextParameters.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":
case "streamName": getOrCreateConfiguration(target).setStreamName(property(camelContext, java.lang.String.class, value)); return true;
case "tlscertificatepath":
case "tlsCertificatePath": getOrCreateConfiguration(target).setTlsCertificatePath(property(camelContext, java.lang.String.class, value)); return true;
case "tlsenabled":
case "tlsEnabled": getOrCreateConfiguration(target).setTlsEnabled(property(camelContext, boolean.class, value)); return true;
case "useglobalsslcontextparameters":
case "useGlobalSslContextParameters": target.setUseGlobalSslContextParameters(property(camelContext, boolean.class, value)); return true;
case "username": getOrCreateConfiguration(target).setUsername(property(camelContext, java.lang.String.class, value)); return true;
default: return false;
}
Expand Down Expand Up @@ -126,12 +134,20 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
case "replicationFactor": return java.lang.Short.class;
case "shutdowntimeout":
case "shutdownTimeout": return int.class;
case "sslcontextparameters":
case "sslContextParameters": return org.apache.camel.support.jsse.SSLContextParameters.class;
case "startingoffset":
case "startingOffset": return java.lang.Long.class;
case "streamid":
case "streamId": return java.lang.Long.class;
case "streamname":
case "streamName": return java.lang.String.class;
case "tlscertificatepath":
case "tlsCertificatePath": return java.lang.String.class;
case "tlsenabled":
case "tlsEnabled": return boolean.class;
case "useglobalsslcontextparameters":
case "useGlobalSslContextParameters": return boolean.class;
case "username": return java.lang.String.class;
default: return null;
}
Expand Down Expand Up @@ -182,12 +198,20 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
case "replicationFactor": return getOrCreateConfiguration(target).getReplicationFactor();
case "shutdowntimeout":
case "shutdownTimeout": return getOrCreateConfiguration(target).getShutdownTimeout();
case "sslcontextparameters":
case "sslContextParameters": return getOrCreateConfiguration(target).getSslContextParameters();
case "startingoffset":
case "startingOffset": return getOrCreateConfiguration(target).getStartingOffset();
case "streamid":
case "streamId": return getOrCreateConfiguration(target).getStreamId();
case "streamname":
case "streamName": return getOrCreateConfiguration(target).getStreamName();
case "tlscertificatepath":
case "tlsCertificatePath": return getOrCreateConfiguration(target).getTlsCertificatePath();
case "tlsenabled":
case "tlsEnabled": return getOrCreateConfiguration(target).isTlsEnabled();
case "useglobalsslcontextparameters":
case "useGlobalSslContextParameters": return target.isUseGlobalSslContextParameters();
case "username": return getOrCreateConfiguration(target).getUsername();
default: return null;
}
Expand Down
18 changes: 18 additions & 0 deletions ...camel-iggy/src/generated/java/org/apache/camel/component/iggy/IggyEndpointConfigurer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,12 +65,18 @@ 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 "sslcontextparameters":
case "sslContextParameters": target.getConfiguration().setSslContextParameters(property(camelContext, org.apache.camel.support.jsse.SSLContextParameters.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":
case "streamName": target.getConfiguration().setStreamName(property(camelContext, java.lang.String.class, value)); return true;
case "tlscertificatepath":
case "tlsCertificatePath": target.getConfiguration().setTlsCertificatePath(property(camelContext, java.lang.String.class, value)); return true;
case "tlsenabled":
case "tlsEnabled": target.getConfiguration().setTlsEnabled(property(camelContext, boolean.class, value)); return true;
case "username": target.getConfiguration().setUsername(property(camelContext, java.lang.String.class, value)); return true;
default: return false;
}
Expand Down Expand Up @@ -121,12 +127,18 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
case "replicationFactor": return java.lang.Short.class;
case "shutdowntimeout":
case "shutdownTimeout": return int.class;
case "sslcontextparameters":
case "sslContextParameters": return org.apache.camel.support.jsse.SSLContextParameters.class;
case "startingoffset":
case "startingOffset": return java.lang.Long.class;
case "streamid":
case "streamId": return java.lang.Long.class;
case "streamname":
case "streamName": return java.lang.String.class;
case "tlscertificatepath":
case "tlsCertificatePath": return java.lang.String.class;
case "tlsenabled":
case "tlsEnabled": return boolean.class;
case "username": return java.lang.String.class;
default: return null;
}
Expand Down Expand Up @@ -178,12 +190,18 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
case "replicationFactor": return target.getConfiguration().getReplicationFactor();
case "shutdowntimeout":
case "shutdownTimeout": return target.getConfiguration().getShutdownTimeout();
case "sslcontextparameters":
case "sslContextParameters": return target.getConfiguration().getSslContextParameters();
case "startingoffset":
case "startingOffset": return target.getConfiguration().getStartingOffset();
case "streamid":
case "streamId": return target.getConfiguration().getStreamId();
case "streamname":
case "streamName": return target.getConfiguration().getStreamName();
case "tlscertificatepath":
case "tlsCertificatePath": return target.getConfiguration().getTlsCertificatePath();
case "tlsenabled":
case "tlsEnabled": return target.getConfiguration().isTlsEnabled();
case "username": return target.getConfiguration().getUsername();
default: return null;
}
Expand Down
5 changes: 4 additions & 1 deletion ...camel-iggy/src/generated/java/org/apache/camel/component/iggy/IggyEndpointUriFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public class IggyEndpointUriFactory extends org.apache.camel.support.component.E
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Map<String, String> MULTI_VALUE_PREFIXES;
static {
Set<String> props = new HashSet<>(28);
Set<String> props = new HashSet<>(31);
props.add("autoCommit");
props.add("autoCreateStream");
props.add("autoCreateTopic");
Expand All @@ -47,9 +47,12 @@ public class IggyEndpointUriFactory extends org.apache.camel.support.component.E
props.add("port");
props.add("replicationFactor");
props.add("shutdownTimeout");
props.add("sslContextParameters");
props.add("startingOffset");
props.add("streamId");
props.add("streamName");
props.add("tlsCertificatePath");
props.add("tlsEnabled");
props.add("topicName");
props.add("username");
PROPERTY_NAMES = Collections.unmodifiableSet(props);
Expand Down
Loading
Loading