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.git
The following commit(s) were added to refs/heads/main by this push:
new 66ea41baa4e Regen
66ea41baa4e is described below
commit 66ea41baa4e6e1a1263939debba52cca24ecdec6
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Jul 20 11:36:54 2023 +0200
Regen
---
.../apache/camel/catalog/components/google-calendar.json | 2 +-
.../apache/camel/catalog/components/google-drive.json | 4 ++--
.../camel/component/aws2/kinesis/Kinesis2Consumer.java | 16 +++++++---------
.../component/kafka/integration/KafkaConsumerAuthIT.java | 1 -
.../kafka/integration/KafkaConsumerIdempotentIT.java | 3 ++-
5 files changed, 12 insertions(+), 14 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-calendar.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-calendar.json
index 5253e242b46..60d9797c41b 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-calendar.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-calendar.json
@@ -80,7 +80,7 @@
"acl": { "consumerOnly": false, "producerOnly": false, "description": "The
acl collection of methods", "methods": { "delete": { "description": "Deletes an
access control rule", "signatures": [
"com.google.api.services.calendar.Calendar$Acl$Delete delete(String calendarId,
String ruleId)" ] }, "get": { "description": "Returns an access control rule",
"signatures": [ "com.google.api.services.calendar.Calendar$Acl$Get get(String
calendarId, String ruleId)" ] }, "insert": { "description" [...]
"calendars": { "consumerOnly": false, "producerOnly": false,
"description": "The calendars collection of methods", "methods": { "clear": {
"description": "Clears a primary calendar", "signatures": [
"com.google.api.services.calendar.Calendar$Calendars$Clear clear(String
calendarId)" ] }, "delete": { "description": "Deletes a secondary calendar",
"signatures": [ "com.google.api.services.calendar.Calendar$Calendars$Delete
delete(String calendarId)" ] }, "get": { "description": "Returns [...]
"channels": { "consumerOnly": false, "producerOnly": false, "description":
"The channels collection of methods", "methods": { "stop": { "description":
"Stop watching resources through this channel", "signatures": [
"com.google.api.services.calendar.Calendar$Channels$Stop
stop(com.google.api.services.calendar.model.Channel content)" ] } } },
- "events": { "consumerOnly": false, "producerOnly": false, "description":
"The events collection of methods", "methods": { "calendarImport": {
"description": "Imports an event", "signatures": [
"com.google.api.services.calendar.Calendar$Events$CalendarImport
calendarImport(String calendarId, com.google.api.services.calendar.model.Event
content)" ] }, "delete": { "description": "Deletes an event", "signatures": [
"com.google.api.services.calendar.Calendar$Events$Delete delete(String ca [...]
+ "events": { "consumerOnly": false, "producerOnly": false, "description":
"The events collection of methods", "methods": { "calendarImport": {
"description": "Imports an event", "signatures": [
"com.google.api.services.calendar.Calendar$Events$CalendarImport
calendarImport(String calendarId, com.google.api.services.calendar.model.Event
content)" ] }, "delete": { "description": "Deletes an event", "signatures": [
"com.google.api.services.calendar.Calendar$Events$Delete delete(String ca [...]
"freebusy": { "consumerOnly": false, "producerOnly": false, "description":
"The freebusy collection of methods", "methods": { "query": { "description":
"Returns free\/busy information for a set of calendars", "signatures": [
"com.google.api.services.calendar.Calendar$Freebusy$Query
query(com.google.api.services.calendar.model.FreeBusyRequest content)" ] } } },
"list": { "consumerOnly": false, "producerOnly": false, "description":
"The calendarList collection of methods", "methods": { "delete": {
"description": "Removes a calendar from the user's calendar list",
"signatures": [ "com.google.api.services.calendar.Calendar$CalendarList$Delete
delete(String calendarId)" ] }, "get": { "description": "Returns a calendar
from the user's calendar list", "signatures": [
"com.google.api.services.calendar.Calendar$CalendarList$Get get(String
calendarI [...]
"settings": { "consumerOnly": false, "producerOnly": false, "description":
"The settings collection of methods", "methods": { "get": { "description":
"Returns a single user setting", "signatures": [
"com.google.api.services.calendar.Calendar$Settings$Get get(String setting)" ]
}, "watch": { "description": "Watch for changes to Settings resources",
"signatures": [ "com.google.api.services.calendar.Calendar$Settings$Watch
watch(com.google.api.services.calendar.model.Channel content)" ] } } }
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-drive.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-drive.json
index e766dc9c12d..ef89165034f 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-drive.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/google-drive.json
@@ -78,7 +78,7 @@
"drive-children": { "consumerOnly": false, "producerOnly": false,
"description": "The children collection of methods", "methods": { "delete": {
"description": "Removes a child from a folder", "signatures": [
"com.google.api.services.drive.Drive$Children$Delete delete(String folderId,
String childId)" ] }, "get": { "description": "Gets a specific child
reference", "signatures": [ "com.google.api.services.drive.Drive$Children$Get
get(String folderId, String childId)" ] }, "insert": { " [...]
"drive-comments": { "consumerOnly": false, "producerOnly": false,
"description": "The comments collection of methods", "methods": { "delete": {
"description": "Deletes a comment", "signatures": [
"com.google.api.services.drive.Drive$Comments$Delete delete(String fileId,
String commentId)" ] }, "get": { "description": "Gets a comment by ID",
"signatures": [ "com.google.api.services.drive.Drive$Comments$Get get(String
fileId, String commentId)" ] }, "insert": { "description": "Creates [...]
"drive-drives": { "consumerOnly": false, "producerOnly": false,
"description": "The drives collection of methods", "methods": { "delete": {
"description": "Permanently deletes a shared drive for which the user is an
organizer", "signatures": [ "com.google.api.services.drive.Drive$Drives$Delete
delete(String driveId)" ] }, "get": { "description": "Gets a shared drive's
metadata by ID", "signatures": [
"com.google.api.services.drive.Drive$Drives$Get get(String driveId)" ] },
"hide": { [...]
- "drive-files": { "consumerOnly": false, "producerOnly": false,
"description": "The files collection of methods", "methods": { "copy": {
"description": "Creates a copy of the specified file", "signatures": [
"com.google.api.services.drive.Drive$Files$Copy copy(String fileId,
com.google.api.services.drive.model.File content)" ] }, "delete": {
"description": "Permanently deletes a file by ID", "signatures": [
"com.google.api.services.drive.Drive$Files$Delete delete(String fileId)" ] },
[...]
+ "drive-files": { "consumerOnly": false, "producerOnly": false,
"description": "The files collection of methods", "methods": { "copy": {
"description": "Creates a copy of the specified file", "signatures": [
"com.google.api.services.drive.Drive$Files$Copy copy(String fileId,
com.google.api.services.drive.model.File content)" ] }, "delete": {
"description": "Permanently deletes a file by ID", "signatures": [
"com.google.api.services.drive.Drive$Files$Delete delete(String fileId)" ] },
[...]
"drive-parents": { "consumerOnly": false, "producerOnly": false,
"description": "The parents collection of methods", "methods": { "delete": {
"description": "Removes a parent from a file", "signatures": [
"com.google.api.services.drive.Drive$Parents$Delete delete(String fileId,
String parentId)" ] }, "get": { "description": "Gets a specific parent
reference", "signatures": [ "com.google.api.services.drive.Drive$Parents$Get
get(String fileId, String parentId)" ] }, "insert": { "descri [...]
"drive-permissions": { "consumerOnly": false, "producerOnly": false,
"description": "The permissions collection of methods", "methods": { "delete":
{ "description": "Deletes a permission from a file or shared drive",
"signatures": [ "com.google.api.services.drive.Drive$Permissions$Delete
delete(String fileId, String permissionId)" ] }, "get": { "description": "Gets
a permission by ID", "signatures": [
"com.google.api.services.drive.Drive$Permissions$Get get(String fileId, String
perm [...]
"drive-properties": { "consumerOnly": false, "producerOnly": false,
"description": "The properties collection of methods", "methods": { "delete": {
"description": "Deletes a property", "signatures": [
"com.google.api.services.drive.Drive$Properties$Delete delete(String fileId,
String propertyKey)" ] }, "get": { "description": "Gets a property by its key",
"signatures": [ "com.google.api.services.drive.Drive$Properties$Get get(String
fileId, String propertyKey)" ] }, "insert": { "desc [...]
@@ -93,7 +93,7 @@
"drive-children": { "methods": { "delete": { "properties": { "childId": {
"index": 0, "kind": "parameter", "displayName": "Child Id", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The ID of the child", "optional": false }, "folderId": {
"index": 1, "kind": "parameter", "displayName": "Folder Id", "group": "common",
"label": "", "required": false, "type": "s [...]
"drive-comments": { "methods": { "delete": { "properties": { "commentId":
{ "index": 0, "kind": "parameter", "displayName": "Comment Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The ID of the comment", "optional": false }, "fileId": {
"index": 1, "kind": "parameter", "displayName": "File Id", "group": "common",
"label": "", "required": false, "type": [...]
"drive-drives": { "methods": { "delete": { "properties": { "driveId": {
"index": 0, "kind": "parameter", "displayName": "Drive Id", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The ID of the shared drive", "optional": false } } }, "get": {
"properties": { "driveId": { "index": 0, "kind": "parameter", "displayName":
"Drive Id", "group": "common", "label": " [...]
- "drive-files": { "methods": { "copy": { "properties": { "content": {
"index": 0, "kind": "parameter", "displayName": "Content", "group": "common",
"label": "", "required": false, "type": "object", "javaType":
"com.google.api.services.drive.model.File", "deprecated": false, "autowired":
false, "secret": false, "description": "The
com.google.api.services.drive.model.File", "optional": false }, "fileId": {
"index": 1, "kind": "parameter", "displayName": "File Id", "group": "common",
"la [...]
+ "drive-files": { "methods": { "copy": { "properties": { "file": { "index":
0, "kind": "parameter", "displayName": "File", "group": "common", "label": "",
"required": false, "type": "object", "javaType":
"com.google.api.services.drive.model.File", "deprecated": false, "autowired":
false, "secret": false, "description": "The
com.google.api.services.drive.model.File", "optional": false }, "fileId": {
"index": 1, "kind": "parameter", "displayName": "File Id", "group": "common",
"label": [...]
"drive-parents": { "methods": { "delete": { "properties": { "fileId": {
"index": 0, "kind": "parameter", "displayName": "File Id", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The ID of the file", "optional": false }, "parentId": {
"index": 1, "kind": "parameter", "displayName": "Parent Id", "group": "common",
"label": "", "required": false, "type": "strin [...]
"drive-permissions": { "methods": { "delete": { "properties": { "fileId":
{ "index": 0, "kind": "parameter", "displayName": "File Id", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The ID for the file or shared drive", "optional": false },
"permissionId": { "index": 1, "kind": "parameter", "displayName": "Permission
Id", "group": "common", "label": "", "req [...]
"drive-properties": { "methods": { "delete": { "properties": { "fileId": {
"index": 0, "kind": "parameter", "displayName": "File Id", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The ID of the file", "optional": false }, "propertyKey": {
"index": 1, "kind": "parameter", "displayName": "Property Key", "group":
"common", "label": "", "required": false, "type [...]
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Consumer.java
b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Consumer.java
index 323b9c961d4..696b56e165a 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Consumer.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Consumer.java
@@ -16,6 +16,12 @@
*/
package org.apache.camel.component.aws2.kinesis;
+import java.util.ArrayDeque;
+import java.util.List;
+import java.util.Queue;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.atomic.AtomicInteger;
+
import org.apache.camel.AsyncCallback;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
@@ -29,13 +35,6 @@ import org.apache.camel.util.CastUtils;
import org.apache.camel.util.ObjectHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
-import java.util.ArrayDeque;
-import java.util.List;
-import java.util.Queue;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.atomic.AtomicInteger;
-
import software.amazon.awssdk.services.kinesis.KinesisAsyncClient;
import software.amazon.awssdk.services.kinesis.KinesisClient;
import software.amazon.awssdk.services.kinesis.model.GetRecordsRequest;
@@ -101,7 +100,6 @@ public class Kinesis2Consumer extends
ScheduledBatchPollingConsumer implements R
result = getClient().getRecords(req);
}
-
try {
Queue<Exchange> exchanges =
createExchanges(result.records());
processedExchangeCount.getAndSet(processBatch(CastUtils.cast(exchanges)));
@@ -237,7 +235,7 @@ public class Kinesis2Consumer extends
ScheduledBatchPollingConsumer implements R
private boolean hasSequenceNumber() {
return !getEndpoint().getConfiguration().getSequenceNumber().isEmpty()
&&
(getEndpoint().getConfiguration().getIteratorType().equals(ShardIteratorType.AFTER_SEQUENCE_NUMBER)
- ||
getEndpoint().getConfiguration().getIteratorType().equals(ShardIteratorType.AT_SEQUENCE_NUMBER));
+ ||
getEndpoint().getConfiguration().getIteratorType().equals(ShardIteratorType.AT_SEQUENCE_NUMBER));
}
@Override
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAuthIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAuthIT.java
index d1e386d54d5..a7a0575cec8 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAuthIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAuthIT.java
@@ -19,7 +19,6 @@ package org.apache.camel.component.kafka.integration;
import java.util.Collections;
import java.util.Map;
import java.util.Properties;
-import java.util.concurrent.ExecutionException;
import java.util.stream.StreamSupport;
import org.apache.camel.CamelContext;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
index dc76acaf17f..242e2488755 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
@@ -44,7 +44,8 @@ public class KafkaConsumerIdempotentIT extends
KafkaConsumerIdempotentTestSuppor
private final int size = 200;
@BindToRegistry("kafkaIdempotentRepository")
- private final KafkaIdempotentRepository testIdempotent = new
KafkaIdempotentRepository("TEST_IDEMPOTENT", getBootstrapServers());
+ private final KafkaIdempotentRepository testIdempotent
+ = new KafkaIdempotentRepository("TEST_IDEMPOTENT",
getBootstrapServers());
@BeforeEach
public void before() {
