(camel) branch main updated: CAMEL-20129 - Upgrade Localstack to version 3.0.0 (#12090)

[acosentino]

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.git


The following commit(s) were added to refs/heads/main by this push:
     new fa37ef23f30 CAMEL-20129 - Upgrade Localstack to version 3.0.0 (#12090)
fa37ef23f30 is described below

commit fa37ef23f30c370bd15c904ed2bf7a6247a79e29
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Nov 20 10:56:38 2023 +0100

    CAMEL-20129 - Upgrade Localstack to version 3.0.0 (#12090)
    
    * CAMEL-20129 - Upgrade Localstack container image to version 3.0.0
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
    
    * Regen
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
    
    ---------
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java       | 3 ++-
 .../java/org/apache/camel/test/infra/aws2/services/AWSContainer.java   | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java
 
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java
index 3851cd94397..65a0afc328e 100644
--- 
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java
+++ 
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java
@@ -44,7 +44,8 @@ public class AWS2SQSCloudEventDataTypeTransformer extends 
Transformer {
         headers.put(CloudEvents.CAMEL_CLOUD_EVENT_TYPE, 
"org.apache.camel.event.aws.sqs.receiveMessage");
 
         if (message.getHeaders().containsKey(Sqs2Constants.RECEIPT_HANDLE)) {
-            headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE, "aws.sqs.queue." 
+ message.getHeader(Sqs2Constants.RECEIPT_HANDLE, String.class));
+            headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE,
+                    "aws.sqs.queue." + 
message.getHeader(Sqs2Constants.RECEIPT_HANDLE, String.class));
         }
 
         headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SUBJECT, 
message.getHeader(Sqs2Constants.MESSAGE_ID, String.class));
diff --git 
a/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
 
b/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
index 23a3f2bc50b..11beeb5fb31 100644
--- 
a/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
+++ 
b/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
@@ -37,7 +37,7 @@ import 
software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
  */
 public class AWSContainer extends GenericContainer<AWSContainer> {
 
-    public static final String LOCALSTACK_CONTAINER = 
"localstack/localstack:2.3.2";
+    public static final String LOCALSTACK_CONTAINER = 
"localstack/localstack:3.0.0";
 
     private static final Logger LOG = 
LoggerFactory.getLogger(AWSLocalContainerService.class);
     private static final int SERVICE_PORT = 4566;