This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new b6577cc [create-pull-request] automated change
b6577cc is described below
commit b6577cc593a6739b1fed0ca13d0cf4738fab2f78
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Mar 2 01:10:13 2022 +0000
[create-pull-request] automated change
---
.../catalog/components/aws2-kinesis.json | 2 --
.../springboot/catalog/components/couchdb.json | 1 -
.../camel/springboot/catalog/components/file.json | 1 -
.../camel/springboot/catalog/components/kafka.json | 2 --
.../springboot/catalog/components/netty-http.json | 8 ++++----
.../springboot/catalog/components/quartz.json | 1 -
.../src/main/docs/aws2-kinesis.json | 6 ------
.../springboot/Kinesis2ComponentConfiguration.java | 16 ----------------
.../springboot/Kinesis2ComponentConverter.java | 2 --
.../camel-kafka-starter/src/main/docs/kafka.json | 6 ------
.../springboot/KafkaComponentConfiguration.java | 22 ----------------------
.../kafka/springboot/KafkaComponentConverter.java | 2 --
.../src/main/docs/netty-http.json | 4 ++--
.../NettyHttpComponentConfiguration.java | 14 ++++++--------
14 files changed, 12 insertions(+), 75 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
index 7ef3c83..ad40d37 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
@@ -36,7 +36,6 @@
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"iteratorType": { "kind": "property", "displayName": "Iterator Type",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.kinesis.model.ShardIteratorType",
"enum": [ "AT_SEQUENCE_NUMBER", "AFTER_SEQUENCE_NUMBER", "TRIM_HORIZON",
"LATEST", "AT_TIMESTAMP", "null" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "TRIM_HORIZON", "configurationClass":
"org.apache.camel.component.aws2.kinesi [...]
"maxResultsPerRequest": { "kind": "property", "displayName": "Max Results
Per Request", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Maximum number of
records that will be fetched in each poll" },
- "resumeStrategy": { "kind": "property", "displayName": "Resume Strategy",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"KinesisUserConfigurationResumeStrategy", "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "descri [...]
"sequenceNumber": { "kind": "property", "displayName": "Sequence Number",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "The sequence number to
start polling from. Required if iteratorType is set to AFTER_SEQUENCE_NUMBER or
[...]
"shardClosed": { "kind": "property", "displayName": "Shard Closed",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.aws2.kinesis.Kinesis2ShardClosedStrategyEnum",
"enum": [ "ignore", "fail", "silent" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "ignore", "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "des [...]
"shardId": { "kind": "property", "displayName": "Shard Id", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Defines which shardId in
the Kinesis stream to get records from" },
@@ -60,7 +59,6 @@
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
"iteratorType": { "kind": "parameter", "displayName": "Iterator Type",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.kinesis.model.ShardIteratorType",
"enum": [ "AT_SEQUENCE_NUMBER", "AFTER_SEQUENCE_NUMBER", "TRIM_HORIZON",
"LATEST", "AT_TIMESTAMP", "null" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "TRIM_HORIZON", "configurationClass":
"org.apache.camel.component.aws2.kines [...]
"maxResultsPerRequest": { "kind": "parameter", "displayName": "Max Results
Per Request", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Maximum number of
records that will be fetched in each poll" },
- "resumeStrategy": { "kind": "parameter", "displayName": "Resume Strategy",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"KinesisUserConfigurationResumeStrategy", "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "descr [...]
"sendEmptyMessageWhenIdle": { "kind": "parameter", "displayName": "Send
Empty Message When Idle", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "If
the polling consumer did not poll any files, you can enable this option to send
an empty message (no body) instead." },
"sequenceNumber": { "kind": "parameter", "displayName": "Sequence Number",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "The sequence number to
start polling from. Required if iteratorType is set to AFTER_SEQUENCE_NUMBER or
[...]
"shardClosed": { "kind": "parameter", "displayName": "Shard Closed",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.aws2.kinesis.Kinesis2ShardClosedStrategyEnum",
"enum": [ "ignore", "fail", "silent" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "ignore", "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "de [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
index bc0a51a..7f44d43 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/couchdb.json
@@ -35,7 +35,6 @@
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
"deletes": { "kind": "parameter", "displayName": "Deletes", "group":
"consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Document deletes are published as
events" },
"heartbeat": { "kind": "parameter", "displayName": "Heartbeat", "group":
"consumer", "label": "consumer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "30000", "description": "How often to send an empty message to
keep socket alive in millis" },
- "resumeStrategy": { "kind": "parameter", "displayName": "Resume Strategy",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.couchdb.consumer.CouchDbResumeStrategy",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
a custom resume strategy for tracking changes from CouchDB. It allows tracking
from a specific point (i.e.: since the given update sequence, the latest
sequence, etc)." },
"style": { "kind": "parameter", "displayName": "Style", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "all_docs", "main_only" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"main_only", "description": "Specifies how many revisions are returned in the
changes array. The default, main_only, will only return the current winning
revision; all_docs will return all leaf revisions (inclu [...]
"updates": { "kind": "parameter", "displayName": "Updates", "group":
"consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Document inserts\/updates are
published as events" },
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
index 79c1405..b65234f 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file.json
@@ -49,7 +49,6 @@
"pollStrategy": { "kind": "parameter", "displayName": "Poll Strategy",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation [...]
"probeContentType": { "kind": "parameter", "displayName": "Probe Content
Type", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"description": "Whether to enable probing of the content type. If enable then
the consumer uses Files#probeContentType(java.nio.file.Path) to determine the
content-type of the file, and store that as a he [...]
"processStrategy": { "kind": "parameter", "displayName": "Process
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.component.file.GenericFileProcessStrategy<java.io.File>",
"deprecated": false, "autowired": false, "secret": false, "description": "A
pluggable org.apache.camel.component.file.GenericFileProcessStrategy allowing
you to implement your own readLock option or similar. Can also be used [...]
- "resumeStrategy": { "kind": "parameter", "displayName": "Resume Strategy",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.file.consumer.FileConsumerResumeStrategy",
"deprecated": false, "autowired": false, "secret": false, "description": "Set a
resume strategy for files. This makes it possible to define a strategy for
resuming reading files after the last point before stopping the application.
[...]
"startingDirectoryMustExist": { "kind": "parameter", "displayName":
"Starting Directory Must Exist", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the starting directory must
exist. Mind that the autoCreate option is default enabled, which means the
starting directory is normally auto created if it doesn' [...]
"startingDirectoryMustHaveAccess": { "kind": "parameter", "displayName":
"Starting Directory Must Have Access", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the starting directory has
access permissions. Mind that the startingDirectoryMustExist parameter must be
set to true in order to verify that the di [...]
"appendChars": { "kind": "parameter", "displayName": "Append Chars",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Used to append characters (text) after writing
files. This can for example be used to add new lines or other separators when
writing and appending new files or existing files. To specify new-line (slash-n
or slash-r) or tab (slash-t) [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
index d36417d..73a2e4e 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
@@ -55,7 +55,6 @@
"partitionAssignor": { "kind": "property", "displayName": "Partition
Assignor", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The class name of the partition assignme [...]
"pollOnError": { "kind": "property", "displayName": "Poll On Error",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [
"DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "ERROR_HANDLER",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "de [...]
"pollTimeoutMs": { "kind": "property", "displayName": "Poll Timeout Ms",
"group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "java.lang.Long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The timeout used when polling the
KafkaConsumer." },
- "resumeStrategy": { "kind": "property", "displayName": "Resume Strategy",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy",
"deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This option allows the
user to set a custom resume s [...]
"seekTo": { "kind": "property", "displayName": "Seek To", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning [...]
"sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "10000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The timeout used to detect failures when using
Kafka's group management facilities." },
"specificAvroReader": { "kind": "property", "displayName": "Specific Avro
Reader", "group": "consumer", "label": "confluent,consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This enables the use of a specific Avro reader
for use with the Confluent Platf [...]
@@ -161,7 +160,6 @@
"partitionAssignor": { "kind": "parameter", "displayName": "Partition
Assignor", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The class name of the partition assignm [...]
"pollOnError": { "kind": "parameter", "displayName": "Poll On Error",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [
"DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "ERROR_HANDLER",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "d [...]
"pollTimeoutMs": { "kind": "parameter", "displayName": "Poll Timeout Ms",
"group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "java.lang.Long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "5000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The timeout used when polling the
KafkaConsumer." },
- "resumeStrategy": { "kind": "parameter", "displayName": "Resume Strategy",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy",
"deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "This option allows the
user to set a custom resume [...]
"seekTo": { "kind": "parameter", "displayName": "Seek To", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Set if KafkaConsumer will read from beginning
or end on startup: beginning : read from beginning [...]
"sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "10000", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The timeout used to detect failures when using
Kafka's group management facilities." },
"specificAvroReader": { "kind": "parameter", "displayName": "Specific Avro
Reader", "group": "consumer", "label": "confluent,consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This enables the use of a specific Avro reader
for use with the Confluent Plat [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
index 2f77450..5dbad6d 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
@@ -80,9 +80,9 @@
"allowDefaultCodec": { "kind": "property", "displayName": "Allow Default
Codec", "group": "codec", "label": "codec", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "The netty component installs a default codec
if both, encoder\/decoder is null and textline is fal [...]
"autoAppendDelimiter": { "kind": "property", "displayName": "Auto Append
Delimiter", "group": "codec", "label": "codec", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "Whether or not to auto append missing end
delimiter when sending using the textline codec." },
"decoderMaxLineLength": { "kind": "property", "displayName": "Decoder Max
Line Length", "group": "codec", "label": "codec", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1024, "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "The max line length to use for the textline
codec." },
- "decoders": { "kind": "property", "displayName": "Decoders", "group":
"codec", "label": "codec", "required": false, "type": "array", "javaType":
"java.util.List<io.netty.channel.ChannelHandler>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "A list of decoders to be used. You can use a
String which have values separated by comma, and have the [...]
+ "decoders": { "kind": "property", "displayName": "Decoders", "group":
"codec", "label": "codec", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.netty.NettyConfiguration",
"configurationField": "configuration", "description": "A list of decoders to be
used. You can use a String which have values separated by comma, and have the
values be looked up in the Re [...]
"delimiter": { "kind": "property", "displayName": "Delimiter", "group":
"codec", "label": "codec", "required": false, "type": "object", "javaType":
"org.apache.camel.component.netty.TextLineDelimiter", "enum": [ "LINE", "NULL"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"LINE", "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "The delimiter to use for the textline codec.
[...]
- "encoders": { "kind": "property", "displayName": "Encoders", "group":
"codec", "label": "codec", "required": false, "type": "array", "javaType":
"java.util.List<io.netty.channel.ChannelHandler>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "A list of encoders to be used. You can use a
String which have values separated by comma, and have the [...]
+ "encoders": { "kind": "property", "displayName": "Encoders", "group":
"codec", "label": "codec", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.netty.NettyConfiguration",
"configurationField": "configuration", "description": "A list of encoders to be
used. You can use a String which have values separated by comma, and have the
values be looked up in the Re [...]
"encoding": { "kind": "property", "displayName": "Encoding", "group":
"codec", "label": "codec", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.netty.NettyConfiguration",
"configurationField": "configuration", "description": "The encoding (a charset
name) to use for the textline codec. If not provided, Camel will use the JVM
default Charset." },
"textline": { "kind": "property", "displayName": "Textline", "group":
"codec", "label": "codec", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.netty.NettyConfiguration", "configurationField":
"configuration", "description": "Only used for TCP. If no codec is specified,
you can use this flag to indicate a text line based codec; if not specif [...]
"enabledProtocols": { "kind": "property", "displayName": "Enabled
Protocols", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "TLSv1,TLSv1.1,TLSv1.2",
"configurationClass": "org.apache.camel.component.netty.NettyConfiguration",
"configurationField": "configuration", "description": "Which protocols to
enable when using SSL" },
@@ -169,8 +169,8 @@
"transferExchange": { "kind": "parameter", "displayName": "Transfer
Exchange", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "Only used for TCP. You
can transfer the exchange over the wire instead of just the b [...]
"workerCount": { "kind": "parameter", "displayName": "Worker Count",
"group": "advanced", "label": "advanced", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "When netty works on nio
mode, it uses default workerCount parameter from Netty (which is
cpu_core_threads x 2). User can [...]
"workerGroup": { "kind": "parameter", "displayName": "Worker Group",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "io.netty.channel.EventLoopGroup", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "To use a explicit
EventLoopGroup as the boss thread pool. For example to share a thread pool w
[...]
- "decoders": { "kind": "parameter", "displayName": "Decoders", "group":
"codec", "label": "codec", "required": false, "type": "array", "javaType":
"java.util.List<io.netty.channel.ChannelHandler>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "A list of decoders to be
used. You can use a String which have values separated by comma, an [...]
- "encoders": { "kind": "parameter", "displayName": "Encoders", "group":
"codec", "label": "codec", "required": false, "type": "array", "javaType":
"java.util.List<io.netty.channel.ChannelHandler>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "A list of encoders to be
used. You can use a String which have values separated by comma, an [...]
+ "decoders": { "kind": "parameter", "displayName": "Decoders", "group":
"codec", "label": "codec", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "A list of decoders to be
used. You can use a String which have values separated by comma, and have the
values be looked up [...]
+ "encoders": { "kind": "parameter", "displayName": "Encoders", "group":
"codec", "label": "codec", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "A list of encoders to be
used. You can use a String which have values separated by comma, and have the
values be looked up [...]
"enabledProtocols": { "kind": "parameter", "displayName": "Enabled
Protocols", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "TLSv1,TLSv1.1,TLSv1.2",
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "Which protocols to
enable when using SSL" },
"keyStoreFile": { "kind": "parameter", "displayName": "Key Store File",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.io.File", "deprecated": false, "autowired": false, "secret":
false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "Client side certificate
keystore to be used for encryption" },
"keyStoreFormat": { "kind": "parameter", "displayName": "Key Store
Format", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "Keystore format to be
used for payload encryption. Defaults to JKS if not set" },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/quartz.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/quartz.json
index bc2277e..64cc022 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/quartz.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/quartz.json
@@ -53,7 +53,6 @@
"triggerParameters": { "kind": "parameter", "displayName": "Trigger
Parameters", "group": "advanced", "label": "advanced", "required": false,
"type": "object", "javaType": "java.util.Map<java.lang.String,
java.lang.Object>", "prefix": "trigger.", "multiValue": true, "deprecated":
false, "autowired": false, "secret": false, "description": "To configure
additional options on the trigger. The parameter timeZone is supported if the
cron option is present. Otherwise the parameters repeatI [...]
"usingFixedCamelContextName": { "kind": "parameter", "displayName": "Using
Fixed Camel Context Name", "group": "advanced", "label": "advanced",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"description": "If it is true, JobDataMap uses the CamelContext name directly
to reference the CamelContext, if it is false, JobDataMap uses use the
CamelContext management name which could be changed d [...]
"autoStartScheduler": { "kind": "parameter", "displayName": "Auto Start
Scheduler", "group": "scheduler", "label": "scheduler", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "Whether or not
the scheduler should be auto started." },
- "startDelayedSeconds": { "kind": "parameter", "displayName": "Start
Delayed Seconds", "group": "scheduler", "label": "scheduler", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "description": "Seconds to wait before starting the
quartz scheduler." },
"triggerStartDelay": { "kind": "parameter", "displayName": "Trigger Start
Delay", "group": "scheduler", "label": "scheduler", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "500", "description": "In case of scheduler
has already started, we want the trigger start slightly after current time to
ensure endpoint is fully started before the job kicks in. Negative value shifts
trigger start time in the past." }
}
}
diff --git
a/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis.json
b/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis.json
index 1a1c6fd..ee68f55 100644
---
a/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis.json
+++
b/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis.json
@@ -239,12 +239,6 @@
"sourceType":
"org.apache.camel.component.aws2.kinesis.springboot.Kinesis2ComponentConfiguration"
},
{
- "name": "camel.component.aws2-kinesis.resume-strategy",
- "type":
"org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy",
- "description": "Defines a resume strategy for AWS Kinesis. The default
strategy reads the sequenceNumber if provided. The option is a
org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy type.",
- "sourceType":
"org.apache.camel.component.aws2.kinesis.springboot.Kinesis2ComponentConfiguration"
- },
- {
"name": "camel.component.aws2-kinesis.secret-key",
"type": "java.lang.String",
"description": "Amazon AWS Secret Key",
diff --git
a/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
b/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
index 8ac0674..1810cda 100644
---
a/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
+++
b/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
@@ -20,7 +20,6 @@ import javax.annotation.Generated;
import org.apache.camel.component.aws2.kinesis.Kinesis2Component;
import org.apache.camel.component.aws2.kinesis.Kinesis2Configuration;
import org.apache.camel.component.aws2.kinesis.Kinesis2ShardClosedStrategyEnum;
-import org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy;
import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
import org.springframework.boot.context.properties.ConfigurationProperties;
import software.amazon.awssdk.core.Protocol;
@@ -115,13 +114,6 @@ public class Kinesis2ComponentConfiguration
*/
private Integer maxResultsPerRequest = 1;
/**
- * Defines a resume strategy for AWS Kinesis. The default strategy reads
the
- * sequenceNumber if provided. The option is a
- * org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy
- * type.
- */
- private KinesisResumeStrategy resumeStrategy;
- /**
* The sequence number to start polling from. Required if iteratorType is
* set to AFTER_SEQUENCE_NUMBER or AT_SEQUENCE_NUMBER
*/
@@ -280,14 +272,6 @@ public class Kinesis2ComponentConfiguration
this.maxResultsPerRequest = maxResultsPerRequest;
}
- public KinesisResumeStrategy getResumeStrategy() {
- return resumeStrategy;
- }
-
- public void setResumeStrategy(KinesisResumeStrategy resumeStrategy) {
- this.resumeStrategy = resumeStrategy;
- }
-
public String getSequenceNumber() {
return sequenceNumber;
}
diff --git
a/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConverter.java
b/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConverter.java
index 4ce5678..9452f49 100644
---
a/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConverter.java
+++
b/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConverter.java
@@ -43,7 +43,6 @@ public class Kinesis2ComponentConverter implements
GenericConverter {
Set<ConvertiblePair> answer = new LinkedHashSet<>();
answer.add(new ConvertiblePair(String.class,
software.amazon.awssdk.services.kinesis.KinesisClient.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class));
- answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy.class));
return answer;
}
@@ -62,7 +61,6 @@ public class Kinesis2ComponentConverter implements
GenericConverter {
switch (targetType.getName()) {
case "software.amazon.awssdk.services.kinesis.KinesisClient":
return applicationContext.getBean(ref,
software.amazon.awssdk.services.kinesis.KinesisClient.class);
case
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration": return
applicationContext.getBean(ref,
org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class);
- case
"org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy":
return applicationContext.getBean(ref,
org.apache.camel.component.aws2.kinesis.consumer.KinesisResumeStrategy.class);
}
return null;
}
diff --git a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
index 67b988b..e0db009 100644
--- a/components-starter/camel-kafka-starter/src/main/docs/kafka.json
+++ b/components-starter/camel-kafka-starter/src/main/docs/kafka.json
@@ -480,12 +480,6 @@
"defaultValue": 30000
},
{
- "name": "camel.component.kafka.resume-strategy",
- "type":
"org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy",
- "description": "This option allows the user to set a custom resume
strategy. The resume strategy is executed when partitions are assigned (i.e.:
when connecting or reconnecting). It allows implementations to customize how to
resume operations and serve as more flexible alternative to the seekTo and the
offsetRepository mechanisms. See the KafkaConsumerResumeStrategy for
implementation details. This option does not affect the auto commit setting. It
is likely that implementations us [...]
- "sourceType":
"org.apache.camel.component.kafka.springboot.KafkaComponentConfiguration"
- },
- {
"name": "camel.component.kafka.retries",
"type": "java.lang.Integer",
"description": "Setting a value greater than zero will cause the client
to resend any record whose send fails with a potentially transient error. Note
that this retry is no different than if the client resent the record upon
receiving the error. Allowing retries will potentially change the ordering of
records because if two records are sent to a single partition, and the first
fails and is retried but the second succeeds, then the second record may appear
first.",
diff --git
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index 15d4f50..1148c38 100644
---
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -25,7 +25,6 @@ import org.apache.camel.component.kafka.KafkaConfiguration;
import org.apache.camel.component.kafka.PollExceptionStrategy;
import org.apache.camel.component.kafka.PollOnError;
import org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory;
-import
org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy;
import org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer;
import org.apache.camel.component.kafka.serde.KafkaHeaderSerializer;
import org.apache.camel.spi.HeaderFilterStrategy;
@@ -285,19 +284,6 @@ public class KafkaComponentConfiguration
*/
private Long pollTimeoutMs = 5000L;
/**
- * This option allows the user to set a custom resume strategy. The resume
- * strategy is executed when partitions are assigned (i.e.: when connecting
- * or reconnecting). It allows implementations to customize how to resume
- * operations and serve as more flexible alternative to the seekTo and the
- * offsetRepository mechanisms. See the KafkaConsumerResumeStrategy for
- * implementation details. This option does not affect the auto commit
- * setting. It is likely that implementations using this setting will also
- * want to evaluate using the manual commit option along with this. The
- * option is a
- *
org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy
type.
- */
- private KafkaConsumerResumeStrategy resumeStrategy;
- /**
* Set if KafkaConsumer will read from beginning or end on startup:
* beginning : read from beginning end : read from end This is replacing
the
* earlier property seekToBeginning
@@ -1029,14 +1015,6 @@ public class KafkaComponentConfiguration
this.pollTimeoutMs = pollTimeoutMs;
}
- public KafkaConsumerResumeStrategy getResumeStrategy() {
- return resumeStrategy;
- }
-
- public void setResumeStrategy(KafkaConsumerResumeStrategy resumeStrategy) {
- this.resumeStrategy = resumeStrategy;
- }
-
public String getSeekTo() {
return seekTo;
}
diff --git
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java
index fb838b3..71484a5 100644
---
a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java
+++
b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java
@@ -45,7 +45,6 @@ public class KafkaComponentConverter implements
GenericConverter {
answer.add(new ConvertiblePair(String.class,
org.apache.camel.spi.HeaderFilterStrategy.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.spi.StateRepository.class));
- answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.kafka.PollExceptionStrategy.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.kafka.serde.KafkaHeaderSerializer.class));
@@ -72,7 +71,6 @@ public class KafkaComponentConverter implements
GenericConverter {
case "org.apache.camel.spi.HeaderFilterStrategy": return
applicationContext.getBean(ref,
org.apache.camel.spi.HeaderFilterStrategy.class);
case
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer": return
applicationContext.getBean(ref,
org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer.class);
case "org.apache.camel.spi.StateRepository": return
applicationContext.getBean(ref, org.apache.camel.spi.StateRepository.class);
- case
"org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy":
return applicationContext.getBean(ref,
org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy.class);
case
"org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory": return
applicationContext.getBean(ref,
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class);
case "org.apache.camel.component.kafka.PollExceptionStrategy":
return applicationContext.getBean(ref,
org.apache.camel.component.kafka.PollExceptionStrategy.class);
case
"org.apache.camel.component.kafka.serde.KafkaHeaderSerializer": return
applicationContext.getBean(ref,
org.apache.camel.component.kafka.serde.KafkaHeaderSerializer.class);
diff --git
a/components-starter/camel-netty-http-starter/src/main/docs/netty-http.json
b/components-starter/camel-netty-http-starter/src/main/docs/netty-http.json
index 41b450f..1f1d58b 100644
--- a/components-starter/camel-netty-http-starter/src/main/docs/netty-http.json
+++ b/components-starter/camel-netty-http-starter/src/main/docs/netty-http.json
@@ -91,7 +91,7 @@
},
{
"name": "camel.component.netty-http.decoders",
- "type": "java.util.List<io.netty.channel.ChannelHandler>",
+ "type": "java.lang.String",
"description": "A list of decoders to be used. You can use a String
which have values separated by comma, and have the values be looked up in the
Registry. Just remember to prefix the value with # so Camel knows it should
lookup.",
"sourceType":
"org.apache.camel.component.netty.http.springboot.NettyHttpComponentConfiguration"
},
@@ -124,7 +124,7 @@
},
{
"name": "camel.component.netty-http.encoders",
- "type": "java.util.List<io.netty.channel.ChannelHandler>",
+ "type": "java.lang.String",
"description": "A list of encoders to be used. You can use a String
which have values separated by comma, and have the values be looked up in the
Registry. Just remember to prefix the value with # so Camel knows it should
lookup.",
"sourceType":
"org.apache.camel.component.netty.http.springboot.NettyHttpComponentConfiguration"
},
diff --git
a/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
b/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
index f15acf5..0974161 100644
---
a/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
+++
b/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
@@ -17,10 +17,8 @@
package org.apache.camel.component.netty.http.springboot;
import java.io.File;
-import java.util.List;
import java.util.Map;
import javax.annotation.Generated;
-import io.netty.channel.ChannelHandler;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.group.ChannelGroup;
import io.netty.handler.ssl.SslHandler;
@@ -356,13 +354,13 @@ public class NettyHttpComponentConfiguration
* separated by comma, and have the values be looked up in the Registry.
* Just remember to prefix the value with # so Camel knows it should
lookup.
*/
- private List<ChannelHandler> decoders;
+ private String decoders;
/**
* A list of encoders to be used. You can use a String which have values
* separated by comma, and have the values be looked up in the Registry.
* Just remember to prefix the value with # so Camel knows it should
lookup.
*/
- private List<ChannelHandler> encoders;
+ private String encoders;
/**
* Which protocols to enable when using SSL
*/
@@ -816,19 +814,19 @@ public class NettyHttpComponentConfiguration
this.workerGroup = workerGroup;
}
- public List<ChannelHandler> getDecoders() {
+ public String getDecoders() {
return decoders;
}
- public void setDecoders(List<ChannelHandler> decoders) {
+ public void setDecoders(String decoders) {
this.decoders = decoders;
}
- public List<ChannelHandler> getEncoders() {
+ public String getEncoders() {
return encoders;
}
- public void setEncoders(List<ChannelHandler> encoders) {
+ public void setEncoders(String encoders) {
this.encoders = encoders;
}
