This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 f891de09899 Regen
f891de09899 is described below
commit f891de09899b067fc4083defc2696422260526b9
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Jul 24 09:08:40 2023 +0200
Regen
---
.../springboot/catalog/components/file-watch.json | 38 ++++++-------
.../FileWatchComponentConfiguration.java | 64 +++++++++++-----------
2 files changed, 51 insertions(+), 51 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file-watch.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file-watch.json
index 69172b1bae8..835e9c55539 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file-watch.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/file-watch.json
@@ -23,12 +23,12 @@
},
"componentProperties": {
"bridgeErrorHandler": { "index": 0, "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 proce [...]
- "concurrentConsumers": { "index": 1, "kind": "property", "displayName":
"Concurrent Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "description": "The number of
concurrent consumers. Increase this value, if your route is slow to prevent
buffering in queue." },
- "fileHasher": { "index": 2, "kind": "property", "displayName": "File
Hasher", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "io.methvin.watcher.hashing.FileHasher", "deprecated":
false, "autowired": false, "secret": false, "defaultValue":
"#murmur3FFileHasher", "description": "Reference to
io.methvin.watcher.hashing.FileHasher. This prevents emitting duplicate events
on some platforms. For working with large files and if you dont need dete [...]
- "pollThreads": { "index": 3, "kind": "property", "displayName": "Poll
Threads", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "description": "The number of threads
polling WatchService. Increase this value, if you see OVERFLOW messages in
log." },
- "queueSize": { "index": 4, "kind": "property", "displayName": "Queue
Size", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2147483647, "description": "Maximum size of
queue between WatchService and consumer. Unbounded by default." },
- "useFileHashing": { "index": 5, "kind": "property", "displayName": "Use
File Hashing", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "Enables or
disables file hashing to detect duplicate events. If you disable this, you can
get some events multiple times on some platforms and JDKs. Check
java.nio.file.WatchService limitations for your [...]
- "autowiredEnabled": { "index": 6, "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 t [...]
+ "useFileHashing": { "index": 1, "kind": "property", "displayName": "Use
File Hashing", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Enables or disables file
hashing to detect duplicate events. If you disable this, you can get some
events multiple times on some platforms and JDKs. Check
java.nio.file.WatchService limitations for your target [...]
+ "autowiredEnabled": { "index": 2, "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 t [...]
+ "concurrentConsumers": { "index": 3, "kind": "property", "displayName":
"Concurrent Consumers", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "description": "The number of
concurrent consumers. Increase this value, if your route is slow to prevent
buffering in queue." },
+ "fileHasher": { "index": 4, "kind": "property", "displayName": "File
Hasher", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "io.methvin.watcher.hashing.FileHasher", "deprecated":
false, "autowired": false, "secret": false, "defaultValue":
"#murmur3FFileHasher", "description": "Reference to
io.methvin.watcher.hashing.FileHasher. This prevents emitting duplicate events
on some platforms. For working with large files and if you dont need dete [...]
+ "pollThreads": { "index": 5, "kind": "property", "displayName": "Poll
Threads", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "description": "The number of threads
polling WatchService. Increase this value, if you see OVERFLOW messages in
log." },
+ "queueSize": { "index": 6, "kind": "property", "displayName": "Queue
Size", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2147483647, "description": "Maximum size of
queue between WatchService and consumer. Unbounded by default." }
},
"headers": {
"CamelFileEventType": { "index": 0, "kind": "header", "displayName": "",
"group": "consumer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "Type of event. Possible values: CREATE, DELETE,
MODIFY.", "constantName":
"org.apache.camel.component.file.watch.FileWatchConstants#EVENT_TYPE_HEADER" },
@@ -43,18 +43,18 @@
"CamelFileLastModified": { "index": 9, "kind": "header", "displayName":
"", "group": "consumer", "label": "", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "A Long value containing the last modified timestamp of
the file.", "constantName":
"org.apache.camel.component.file.watch.FileWatchConstants#FILE_LAST_MODIFIED" }
},
"properties": {
- "path": { "index": 0, "kind": "path", "displayName": "Path", "group":
"consumer", "label": "consumer", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Path of directory to
consume events from." },
- "antInclude": { "index": 1, "kind": "parameter", "displayName": "Ant
Include", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "**", "description": "ANT style pattern
to match files. The file is matched against path relative to endpoint path.
Pattern must be also relative (not starting with slash)" },
- "autoCreate": { "index": 2, "kind": "parameter", "displayName": "Auto
Create", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Auto create directory if
does not exists." },
- "concurrentConsumers": { "index": 3, "kind": "parameter", "displayName":
"Concurrent Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "description": "The number of
concurrent consumers. Increase this value, if your route is slow to prevent
buffering in queue." },
- "events": { "index": 4, "kind": "parameter", "displayName": "Events",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"java.util.Set<org.apache.camel.component.file.watch.constants.FileEventEnum>",
"enum": [ "CREATE", "MODIFY", "DELETE" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "CREATE,MODIFY,DELETE", "description":
"Comma separated list of events to watch." },
- "fileHasher": { "index": 5, "kind": "parameter", "displayName": "File
Hasher", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "io.methvin.watcher.hashing.FileHasher", "deprecated":
false, "autowired": false, "secret": false, "defaultValue":
"#murmur3FFileHasher", "description": "Reference to
io.methvin.watcher.hashing.FileHasher. This prevents emitting duplicate events
on some platforms. For working with large files and if you dont need det [...]
- "pollThreads": { "index": 6, "kind": "parameter", "displayName": "Poll
Threads", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "description": "The number of threads
polling WatchService. Increase this value, if you see OVERFLOW messages in
log." },
- "queueSize": { "index": 7, "kind": "parameter", "displayName": "Queue
Size", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2147483647, "description": "Maximum size of
queue between WatchService and consumer. Unbounded by default." },
- "recursive": { "index": 8, "kind": "parameter", "displayName":
"Recursive", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "Watch recursive
in current and child directories (including newly created directories)." },
- "useFileHashing": { "index": 9, "kind": "parameter", "displayName": "Use
File Hashing", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "Enables or
disables file hashing to detect duplicate events. If you disable this, you can
get some events multiple times on some platforms and JDKs. Check
java.nio.file.WatchService limitations for you [...]
- "bridgeErrorHandler": { "index": 10, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "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 li [...]
- "exceptionHandler": { "index": 11, "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 de [...]
- "exchangePattern": { "index": 12, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "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." }
+ "path": { "index": 0, "kind": "path", "displayName": "Path", "group":
"consumer", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Path of directory to consume events
from." },
+ "antInclude": { "index": 1, "kind": "parameter", "displayName": "Ant
Include", "group": "consumer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "**", "description": "ANT style pattern
to match files. The file is matched against path relative to endpoint path.
Pattern must be also relative (not starting with slash)" },
+ "autoCreate": { "index": 2, "kind": "parameter", "displayName": "Auto
Create", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Auto create directory if
does not exists." },
+ "events": { "index": 3, "kind": "parameter", "displayName": "Events",
"group": "consumer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "CREATE,MODIFY,DELETE", "description": "Comma
separated list of events to watch. Possible values: CREATE,MODIFY,DELETE" },
+ "recursive": { "index": 4, "kind": "parameter", "displayName":
"Recursive", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Watch recursive in
current and child directories (including newly created directories)." },
+ "useFileHashing": { "index": 5, "kind": "parameter", "displayName": "Use
File Hashing", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Enables or disables file
hashing to detect duplicate events. If you disable this, you can get some
events multiple times on some platforms and JDKs. Check
java.nio.file.WatchService limitations for your target [...]
+ "bridgeErrorHandler": { "index": 6, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "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 lik [...]
+ "exceptionHandler": { "index": 7, "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 def [...]
+ "exchangePattern": { "index": 8, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "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." },
+ "concurrentConsumers": { "index": 9, "kind": "parameter", "displayName":
"Concurrent Consumers", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "description": "The number of
concurrent consumers. Increase this value, if your route is slow to prevent
buffering in queue." },
+ "fileHasher": { "index": 10, "kind": "parameter", "displayName": "File
Hasher", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "io.methvin.watcher.hashing.FileHasher", "deprecated":
false, "autowired": false, "secret": false, "defaultValue":
"#murmur3FFileHasher", "description": "Reference to
io.methvin.watcher.hashing.FileHasher. This prevents emitting duplicate events
on some platforms. For working with large files and if you dont need de [...]
+ "pollThreads": { "index": 11, "kind": "parameter", "displayName": "Poll
Threads", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "description": "The number of threads
polling WatchService. Increase this value, if you see OVERFLOW messages in
log." },
+ "queueSize": { "index": 12, "kind": "parameter", "displayName": "Queue
Size", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2147483647, "description": "Maximum size of
queue between WatchService and consumer. Unbounded by default." }
}
}
diff --git
a/components-starter/camel-file-watch-starter/src/main/java/org/apache/camel/component/file/watch/springboot/FileWatchComponentConfiguration.java
b/components-starter/camel-file-watch-starter/src/main/java/org/apache/camel/component/file/watch/springboot/FileWatchComponentConfiguration.java
index b259e115d41..c49c43a6183 100644
---
a/components-starter/camel-file-watch-starter/src/main/java/org/apache/camel/component/file/watch/springboot/FileWatchComponentConfiguration.java
+++
b/components-starter/camel-file-watch-starter/src/main/java/org/apache/camel/component/file/watch/springboot/FileWatchComponentConfiguration.java
@@ -45,6 +45,22 @@ public class FileWatchComponentConfiguration
* will be logged at WARN or ERROR level and ignored.
*/
private Boolean bridgeErrorHandler = false;
+ /**
+ * Enables or disables file hashing to detect duplicate events. If you
+ * disable this, you can get some events multiple times on some platforms
+ * and JDKs. Check java.nio.file.WatchService limitations for your target
+ * platform.
+ */
+ private Boolean useFileHashing = true;
+ /**
+ * 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.
+ */
+ private Boolean autowiredEnabled = true;
/**
* The number of concurrent consumers. Increase this value, if your route
is
* slow to prevent buffering in queue.
@@ -69,22 +85,6 @@ public class FileWatchComponentConfiguration
* default.
*/
private Integer queueSize = 2147483647;
- /**
- * Enables or disables file hashing to detect duplicate events. If you
- * disable this, you can get some events multiple times on some platforms
- * and JDKs. Check java.nio.file.WatchService limitations for your target
- * platform.
- */
- private Boolean useFileHashing = true;
- /**
- * 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.
- */
- private Boolean autowiredEnabled = true;
public Boolean getBridgeErrorHandler() {
return bridgeErrorHandler;
@@ -94,6 +94,22 @@ public class FileWatchComponentConfiguration
this.bridgeErrorHandler = bridgeErrorHandler;
}
+ public Boolean getUseFileHashing() {
+ return useFileHashing;
+ }
+
+ public void setUseFileHashing(Boolean useFileHashing) {
+ this.useFileHashing = useFileHashing;
+ }
+
+ public Boolean getAutowiredEnabled() {
+ return autowiredEnabled;
+ }
+
+ public void setAutowiredEnabled(Boolean autowiredEnabled) {
+ this.autowiredEnabled = autowiredEnabled;
+ }
+
public Integer getConcurrentConsumers() {
return concurrentConsumers;
}
@@ -125,20 +141,4 @@ public class FileWatchComponentConfiguration
public void setQueueSize(Integer queueSize) {
this.queueSize = queueSize;
}
-
- public Boolean getUseFileHashing() {
- return useFileHashing;
- }
-
- public void setUseFileHashing(Boolean useFileHashing) {
- this.useFileHashing = useFileHashing;
- }
-
- public Boolean getAutowiredEnabled() {
- return autowiredEnabled;
- }
-
- public void setAutowiredEnabled(Boolean autowiredEnabled) {
- this.autowiredEnabled = autowiredEnabled;
- }
}
\ No newline at end of file
