chore: Fix AWS SQS Kamelets

- Bring back DuplicateNamingHeaders utils as it is being used by the AWS SQS Kamelet
- Add E2E tests for AWS SQS Kamelets

.github/workflows/e2e-tests.yml

@@ -101,6 +101,7 @@ jobs:
           yaks install --operator-image $YAKS_IMAGE_NAME:$YAKS_VERSION
       - name: YAKS Tests
         run: |
+          yaks run test/aws/sqs $YAKS_RUN_OPTIONS
           yaks run test/transformation $YAKS_RUN_OPTIONS
           yaks run test/extract-field $YAKS_RUN_OPTIONS
           yaks run test/http-sink $YAKS_RUN_OPTIONS

library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/headers/DuplicateNamingHeaders.java

@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.kamelets.utils.headers;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.InvalidPayloadException;
+import org.apache.camel.Processor;
+
+public class DuplicateNamingHeaders implements Processor {
+
+	String prefix;
+	String renamingPrefix;
+	String selectedHeaders;
+	String mode = "all";
+
+	/**
+	 * Default constructor.
+	 */
+	public DuplicateNamingHeaders() {
+	}
+
+	/**
+	 * Constructor using fields.
+	 * 
+	 * @param prefix         a prefix to find all the headers to rename.
+	 * @param renamingPrefix the renaming prefix to use on all the matching headers
+	 */
+	public DuplicateNamingHeaders(String prefix, String renamingPrefix, String selectedHeaders, String mode) {
+		this.prefix = prefix;
+		this.renamingPrefix = renamingPrefix;
+		this.selectedHeaders = selectedHeaders;
+		this.mode = mode;
+	}
+
+	public void process(Exchange ex) throws InvalidPayloadException {
+		Map<String, Object> originalHeaders = ex.getMessage().getHeaders();
+		Map<String, Object> newHeaders = new HashMap<>();
+		for (Map.Entry<String, Object> entry : originalHeaders.entrySet()) {
+			String key = entry.getKey();
+			Object val = entry.getValue();
+			if (prefix != null && mode.equalsIgnoreCase("all")) {
+				if (key.startsWith(prefix)) {
+					String newKey = key.replaceFirst(prefix, renamingPrefix);
+					String subKey = newKey.substring(renamingPrefix.length());
+					String suffix = subKey.replaceAll(String.format("%s|%s|%s", "(?<=[A-Z])(?=[A-Z][a-z])",
+							"(?<=[^A-Z])(?=[A-Z])", "(?<=[A-Za-z])(?=[^A-Za-z])"), ".").toLowerCase();
+					newHeaders.put(renamingPrefix + suffix, val);
+				}
+			} else {
+					if (selectedHeaders != null && mode.equalsIgnoreCase("filtering")) {
+						List<String> headerList = Arrays.asList(selectedHeaders.split(","));
+						for (Iterator<String> iterator = headerList.iterator(); iterator.hasNext();) {
+							String header = iterator.next();
+							if (key.equalsIgnoreCase(header)) {
+								String newKey = key.replaceFirst(prefix, renamingPrefix);
+								String subKey = newKey.substring(renamingPrefix.length());
+								String suffix = subKey
+										.replaceAll(String.format("%s|%s|%s", "(?<=[A-Z])(?=[A-Z][a-z])",
+												"(?<=[^A-Z])(?=[A-Z])", "(?<=[A-Za-z])(?=[^A-Za-z])"), ".")
+										.toLowerCase();
+								newHeaders.put(renamingPrefix + suffix, val);
+							}
+						}
+
+					}
+				}
+			}
+		originalHeaders.putAll(newHeaders);
+		ex.getMessage().setHeaders(originalHeaders);
+	}
+
+	public void setPrefix(String prefix) {
+		this.prefix = prefix;
+	}
+
+	public void setRenamingPrefix(String renamingPrefix) {
+		this.renamingPrefix = renamingPrefix;
+	}
+
+	public void setSelectedHeaders(String selectedHeaders) {
+		this.selectedHeaders = selectedHeaders;
+	}
+
+	public void setMode(String mode) {
+		this.mode = mode;
+	}	
+
+}