fix: SqsContainerOptionsFactoryBean policy - acknowledgementMode mapping

boolivar · boolivar · commit 22bf8df8f7e1 · 2024-10-12T23:38:39.000+03:00
diff --git a/int-aws-support/src/main/java/org/springframework/integration/aws/config/xml/SqsContainerOptionsFactoryBean.java b/int-aws-support/src/main/java/org/springframework/integration/aws/config/xml/SqsContainerOptionsFactoryBean.java
@@ -50,9 +50,12 @@ public void setWaitTimeOut(long seconds) {
     }
 
     public void setMessageDeletionPolicy(String policy) {
-        builder.acknowledgementMode("NO_REDRIVE".equals(policy)
-            ? AcknowledgementMode.ON_SUCCESS
-            : AcknowledgementMode.valueOf(policy));
+        var mode = switch (policy) {
+            case "NO_REDRIVE" -> AcknowledgementMode.ON_SUCCESS;
+            case "NEVER" -> AcknowledgementMode.MANUAL;
+            default -> AcknowledgementMode.valueOf(policy);
+        };
+        builder.acknowledgementMode(mode);
     }
 
     public void setFailOnMissingQueue(boolean fail) {

Original file line number	Diff line number	Diff line change
`@@ -50,9 +50,12 @@ public void setWaitTimeOut(long seconds) {`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`public void setMessageDeletionPolicy(String policy) {`
`53`		`- builder.acknowledgementMode("NO_REDRIVE".equals(policy)`
`54`		`- ? AcknowledgementMode.ON_SUCCESS`
`55`		`- : AcknowledgementMode.valueOf(policy));`
	`53`	`+ var mode = switch (policy) {`
	`54`	`+ case "NO_REDRIVE" -> AcknowledgementMode.ON_SUCCESS;`
	`55`	`+ case "NEVER" -> AcknowledgementMode.MANUAL;`
	`56`	`+ default -> AcknowledgementMode.valueOf(policy);`
	`57`	`+ };`
	`58`	`+ builder.acknowledgementMode(mode);`
`56`	`59`	`}`
`57`	`60`
`58`	`61`	`public void setFailOnMissingQueue(boolean fail) {`