Remove DuplicateNamingHeaders and DeDuplicateNamingHeaders from utils

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Feb 15, 2024 · 1ee8e2a · 1ee8e2a
1 parent a9c5436
commit 1ee8e2a
Show file tree

Hide file tree

Showing 16 changed files with 0 additions and 507 deletions.
diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml
@@ -95,14 +95,6 @@ spec:
     - "camel:core"
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
   template:
-    beans:
-      - name: duplicateHeaders
-        type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
-        properties:
-          prefix: 'CamelAwsKinesis'
-          renamingPrefix: 'aws.kinesis.'
-          mode: 'filtering'
-          selectedHeaders: 'CamelAwsKinesisPartitionKey,CamelAwsKinesisSequenceNumber'
     from:
       uri: aws2-kinesis:{{stream}}
       parameters:
@@ -114,6 +106,4 @@ spec:
         overrideEndpoint: "{{overrideEndpoint}}"
         delay: "{{delay}}"
       steps:
-      - process:
-          ref: "{{duplicateHeaders}}"
       - to: "kamelet:sink"
diff --git a/kamelets/aws-s3-source.kamelet.yaml b/kamelets/aws-s3-source.kamelet.yaml
@@ -160,14 +160,6 @@ spec:
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
     - "camel:kamelet"
   template:
-    beans:
-      - name: renameHeaders
-        type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
-        properties:
-          prefix: 'CamelAwsS3'
-          renamingPrefix: 'aws.s3.'
-          mode: 'filtering'
-          selectedHeaders: 'CamelAwsS3Key,CamelAwsS3BucketName'
     from:
       uri: "aws2-s3:{{bucketNameOrArn}}"
       parameters:
@@ -185,6 +177,4 @@ spec:
         delay: "{{delay}}"
         maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
       steps:
-      - process:
-          ref: "{{renameHeaders}}"
       - to: "kamelet:sink"
diff --git a/kamelets/aws-sqs-source.kamelet.yaml b/kamelets/aws-sqs-source.kamelet.yaml
@@ -192,14 +192,6 @@ spec:
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
     - "camel:kamelet"
   template:
-    beans:
-      - name: renameHeaders
-        type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
-        properties:
-          prefix: 'CamelAwsSqs'
-          renamingPrefix: 'aws.sqs.'
-          mode: 'filtering'
-          selectedHeaders: 'CamelAwsSqsReceiptHandle,CamelAwsSqsMessageId'
     from:
       uri: "aws2-sqs:{{queueNameOrArn}}"
       parameters:
@@ -216,6 +208,4 @@ spec:
         delay: "{{delay}}"
         greedy: "{{greedy}}"
       steps:
-      - process:
-          ref: "{{renameHeaders}}"
       - to: "kamelet:sink"
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -151,23 +151,13 @@ spec:
     - "camel:timer"
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
   template:
-    beans:
-      - name: duplicateHeaders
-        type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
-        properties:
-          prefix: 'CamelAzureStorageBlob'
-          renamingPrefix: 'azure.storage.blob.'
-          mode: 'filtering'
-          selectedHeaders: 'CamelAzureStorageBlobETag,CamelAzureStorageBlobBlobSize'
     from:
       uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
       parameters:
         accessKey: "{{?accessKey}}"
         credentialType: "{{credentialType}}"
         delay: "{{delay}}"
       steps:
-        - process:
-            ref: "{{duplicateHeaders}}"
         - to: "kamelet:sink"
         - choice:
             precondition: true

diff --git a/kamelets/azure-storage-queue-source.kamelet.yaml b/kamelets/azure-storage-queue-source.kamelet.yaml
@@ -136,21 +136,11 @@ spec:
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
     - "camel:core"
   template:
-    beans:
-      - name: renameHeaders
-        type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
-        properties:
-          prefix: 'CamelAzureStorageQueue'
-          renamingPrefix: 'azure.storage.queue.'
-          mode: 'filtering'
-          selectedHeaders: 'CamelAzureStorageQueueMessageId'
     from:
       uri: "azure-storage-queue://{{accountName}}/{{queueName}}"
       parameters:
         accessKey: "{{accessKey}}"
         maxMessages: "{{maxMessages}}"
         credentialType: "{{credentialType}}"
       steps:
-      - process:
-          ref: "{{renameHeaders}}"
       - to: "kamelet:sink"
diff --git a/kamelets/kafka-not-secured-sink.kamelet.yaml b/kamelets/kafka-not-secured-sink.kamelet.yaml
@@ -61,19 +61,9 @@ spec:
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
     - "camel:kamelet"
   template:
-    beans:
-      - name: deDuplicateHeaders
-        type: "#class:org.apache.camel.kamelets.utils.headers.DeDuplicateNamingHeaders"
-        properties:
-          prefix: 'kafka.'
-          renamingPrefix: 'kafka.'
-          mode: 'filtering'
-          selectedHeaders: 'kafka.key,kafka.topic,kafka.override_topic'
     from:
       uri: "kamelet:source"
       steps:
-      - process:
-          ref: "{{deDuplicateHeaders}}"
       - choice:
           when:
           - simple: "${header[key]}"

diff --git a/...utils/src/main/java/org/apache/camel/kamelets/utils/headers/DeDuplicateNamingHeaders.java b/...utils/src/main/java/org/apache/camel/kamelets/utils/headers/DeDuplicateNamingHeaders.java
diff --git a/...s-utils/src/main/java/org/apache/camel/kamelets/utils/headers/DuplicateNamingHeaders.java b/...s-utils/src/main/java/org/apache/camel/kamelets/utils/headers/DuplicateNamingHeaders.java