Fix correct place holder for queuename and account

Author: Pankaj Agrawal

powertools-sqs/src/main/java/software/amazon/lambda/powertools/sqs/internal/BatchContext.java

@@ -8,6 +8,7 @@
 import software.amazon.awssdk.services.sqs.SqsClient;
 import software.amazon.awssdk.services.sqs.model.DeleteMessageBatchRequest;
 import software.amazon.awssdk.services.sqs.model.DeleteMessageBatchRequestEntry;
+import software.amazon.awssdk.services.sqs.model.DeleteMessageBatchResponse;
 import software.amazon.awssdk.services.sqs.model.GetQueueUrlRequest;
 import software.amazon.lambda.powertools.sqs.SQSBatchProcessingException;
 
@@ -68,15 +69,16 @@ private void deleteSuccessMessage() {
                             .build()).collect(toList()))
                     .build();
 
-            client.deleteMessageBatch(request);
+            DeleteMessageBatchResponse deleteMessageBatchResponse = client.deleteMessageBatch(request);
+            LOG.debug(format("Response from delete request %s", deleteMessageBatchResponse));
         }
     }
 
     private String url() {
         String[] arnArray = success.get(0).getEventSourceArn().split(":");
         return client.getQueueUrl(GetQueueUrlRequest.builder()
-                .queueOwnerAWSAccountId(arnArray[1])
-                .queueName(arnArray[2])
+                .queueOwnerAWSAccountId(arnArray[4])
+                .queueName(arnArray[5])
                 .build())
                 .queueUrl();
     }

powertools-sqs/src/test/java/software/amazon/lambda/powertools/sqs/PowertoolsSqsBatchProcessorTest.java

@@ -9,6 +9,7 @@
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
+import org.mockito.ArgumentCaptor;
 import software.amazon.awssdk.services.sqs.SqsClient;
 import software.amazon.awssdk.services.sqs.model.DeleteMessageBatchRequest;
 import software.amazon.awssdk.services.sqs.model.GetQueueUrlRequest;
@@ -107,6 +108,13 @@ void shouldBatchProcessAndDeleteSuccessMessageOnPartialFailures() {
 
         verify(interactionClient).listQueues();
         verify(sqsClient).deleteMessageBatch(any(DeleteMessageBatchRequest.class));
+
+        ArgumentCaptor<GetQueueUrlRequest> captor = ArgumentCaptor.forClass(GetQueueUrlRequest.class);
+        verify(sqsClient).getQueueUrl(captor.capture());
+
+        assertThat(captor.getValue())
+                .hasFieldOrPropertyWithValue("queueName", "my-queue")
+                .hasFieldOrPropertyWithValue("queueOwnerAWSAccountId", "123456789012");
     }
 
     @Test