From b3b8ab911a652b0661e70ec8c4a2ac452814d6cb Mon Sep 17 00:00:00 2001 From: Gaurav Gupta Date: Tue, 12 Mar 2024 22:18:58 +0530 Subject: [PATCH 1/2] FISH-8292 Fixes fetch message for non-s3 storage --- .../cloud/connectors/amazonsqs/api/inbound/SQSPoller.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/AmazonSQS/AmazonSQSJCAAPI/src/main/java/fish/payara/cloud/connectors/amazonsqs/api/inbound/SQSPoller.java b/AmazonSQS/AmazonSQSJCAAPI/src/main/java/fish/payara/cloud/connectors/amazonsqs/api/inbound/SQSPoller.java index 7ec6f23e..b447b17e 100644 --- a/AmazonSQS/AmazonSQSJCAAPI/src/main/java/fish/payara/cloud/connectors/amazonsqs/api/inbound/SQSPoller.java +++ b/AmazonSQS/AmazonSQSJCAAPI/src/main/java/fish/payara/cloud/connectors/amazonsqs/api/inbound/SQSPoller.java @@ -110,8 +110,10 @@ public void run() { Class mdbClass = factory.getEndpointClass(); for (Message message : messages) { for (Method m : mdbClass.getMethods()) { - if (isOnSQSMessageMethod(m) && shouldFetchS3Message(message)) { - message = fetchS3MessageContent(message); + if (isOnSQSMessageMethod(m)) { + if (shouldFetchS3Message(message)) { + message = fetchS3MessageContent(message); + } scheduleSQSWork(m, message); } } From 496ffd8c54d6e42da931f0b7477e47bc406394d8 Mon Sep 17 00:00:00 2001 From: Gaurav Gupta Date: Tue, 12 Mar 2024 22:19:23 +0530 Subject: [PATCH 2/2] FISH-8292 Release AWS SQS Cloud Connector v2.1.0 --- AmazonSQS/AmazonSQSExample/pom.xml | 2 +- .../cloud/connectors/amazonsqs/example/NewTimerSessionBean.java | 2 +- AmazonSQS/AmazonSQSJCAAPI/pom.xml | 2 +- AmazonSQS/AmazonSQSRAR/pom.xml | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/AmazonSQS/AmazonSQSExample/pom.xml b/AmazonSQS/AmazonSQSExample/pom.xml index a6297faf..e211c06a 100644 --- a/AmazonSQS/AmazonSQSExample/pom.xml +++ b/AmazonSQS/AmazonSQSExample/pom.xml @@ -48,7 +48,7 @@ holder. fish.payara.cloud.connectors.amazonsqs amazon-sqs-example - 2.0.0 + 2.1.0 ejb Amazon SQS Example diff --git a/AmazonSQS/AmazonSQSExample/src/main/java/fish/payara/cloud/connectors/amazonsqs/example/NewTimerSessionBean.java b/AmazonSQS/AmazonSQSExample/src/main/java/fish/payara/cloud/connectors/amazonsqs/example/NewTimerSessionBean.java index ef90dca2..7b00e03b 100644 --- a/AmazonSQS/AmazonSQSExample/src/main/java/fish/payara/cloud/connectors/amazonsqs/example/NewTimerSessionBean.java +++ b/AmazonSQS/AmazonSQSExample/src/main/java/fish/payara/cloud/connectors/amazonsqs/example/NewTimerSessionBean.java @@ -55,7 +55,7 @@ @ConnectionFactoryDefinition(name = "java:comp/env/SQSConnectionFactory", description = "SQS Conn Factory", interfaceName = "fish.payara.cloud.connectors.amazonsqs.api.AmazonSQSConnectionFactory", - resourceAdapter = "amazon-sqs-rar-2.0.0", + resourceAdapter = "amazon-sqs-rar-2.1.0", minPoolSize = 2, maxPoolSize = 2, transactionSupport = TransactionSupportLevel.NoTransaction, properties = {"region=${ENV=region}"}) diff --git a/AmazonSQS/AmazonSQSJCAAPI/pom.xml b/AmazonSQS/AmazonSQSJCAAPI/pom.xml index aac07d33..245e6c4e 100644 --- a/AmazonSQS/AmazonSQSJCAAPI/pom.xml +++ b/AmazonSQS/AmazonSQSJCAAPI/pom.xml @@ -48,7 +48,7 @@ holder. fish.payara.cloud.connectors.amazonsqs amazon-sqs-jca-api - 2.0.0 + 2.1.0 jar Amazon SQS JCA Adapter API API classes for the Amazon SQS JCA Adapter diff --git a/AmazonSQS/AmazonSQSRAR/pom.xml b/AmazonSQS/AmazonSQSRAR/pom.xml index ac5f8368..5f7064db 100644 --- a/AmazonSQS/AmazonSQSRAR/pom.xml +++ b/AmazonSQS/AmazonSQSRAR/pom.xml @@ -48,7 +48,7 @@ holder. fish.payara.cloud.connectors.amazonsqs amazon-sqs-rar - 2.0.0 + 2.1.0 rar Amazon SQS JCA Adapter RAR RAR for the Amazon SQS JCA Adapter