Rename counter variables from sqsQueueNotFoundCounter to sqsResourceNotFoundCounter

Author: mzurita-amz

data-prepper-plugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java

@@ -84,7 +84,7 @@ public class SqsWorker implements Runnable {
     private final Counter sqsVisibilityTimeoutChangeFailedCount;
     private final Counter sqsMessageAccessDeniedCounter;
     private final Counter sqsMessageThrottledCounter;
-    private final Counter sqsQueueNotFoundCounter;
+    private final Counter sqsResourceNotFoundCounter;
     private final Timer sqsMessageDelayTimer;
     private final Backoff standardBackoff;
     private final SqsMessageParser sqsMessageParser;
@@ -124,7 +124,7 @@ public SqsWorker(final AcknowledgementSetManager acknowledgementSetManager,
         sqsVisibilityTimeoutChangeFailedCount = pluginMetrics.counter(SQS_VISIBILITY_TIMEOUT_CHANGE_FAILED_COUNT_METRIC_NAME);
         sqsMessageAccessDeniedCounter = pluginMetrics.counter(SQS_MESSAGE_ACCESS_DENIED_METRIC_NAME);
         sqsMessageThrottledCounter = pluginMetrics.counter(SQS_MESSAGE_THROTTLED_METRIC_NAME);
-        sqsQueueNotFoundCounter = pluginMetrics.counter(SQS_RESOURCE_NOT_FOUND_METRIC_NAME);
+        sqsResourceNotFoundCounter = pluginMetrics.counter(SQS_RESOURCE_NOT_FOUND_METRIC_NAME);
     }
 
     @Override
@@ -478,7 +478,7 @@ private void recordSqsException(final AwsServiceException e) {
         } else if (e.statusCode() == 404 ||
                 e instanceof QueueDoesNotExistException ||
                 e instanceof KmsNotFoundException) {
-            sqsQueueNotFoundCounter.increment();
+            sqsResourceNotFoundCounter.increment();
         } else if (e.isThrottlingException() ||
                 e instanceof KmsThrottledException) {
             sqsMessageThrottledCounter.increment();

data-prepper-plugins/sqs-common/src/main/java/org/opensearch/dataprepper/plugins/source/sqs/common/SqsWorkerCommon.java

@@ -64,7 +64,7 @@ public class SqsWorkerCommon {
     private final Counter sqsVisibilityTimeoutChangeFailedCount;
     private final Counter sqsMessageAccessDeniedCounter;
     private final Counter sqsMessageThrottledCounter;
-    private final Counter sqsQueueNotFoundCounter;
+    private final Counter sqsResourceNotFoundCounter;
 
     public SqsWorkerCommon(final Backoff standardBackoff,
                            final PluginMetrics pluginMetrics,
@@ -86,7 +86,7 @@ public SqsWorkerCommon(final Backoff standardBackoff,
         sqsVisibilityTimeoutChangeFailedCount = pluginMetrics.counter(SQS_VISIBILITY_TIMEOUT_CHANGE_FAILED_COUNT_METRIC_NAME);
         sqsMessageAccessDeniedCounter = pluginMetrics.counter(SQS_MESSAGE_ACCESS_DENIED_METRIC_NAME);
         sqsMessageThrottledCounter = pluginMetrics.counter(SQS_MESSAGE_THROTTLED_METRIC_NAME);
-        sqsQueueNotFoundCounter = pluginMetrics.counter(SQS_RESOURCE_NOT_FOUND_METRIC_NAME);
+        sqsResourceNotFoundCounter = pluginMetrics.counter(SQS_RESOURCE_NOT_FOUND_METRIC_NAME);
     }
 
     public List<Message> pollSqsMessages(final String queueUrl,
@@ -238,7 +238,7 @@ public void recordSqsException(final AwsServiceException e) {
         } else if (e.statusCode() == 404 ||
                 e instanceof QueueDoesNotExistException ||
                 e instanceof KmsNotFoundException) {
-            sqsQueueNotFoundCounter.increment();
+            sqsResourceNotFoundCounter.increment();
         } else if (e.isThrottlingException() ||
                 e instanceof KmsThrottledException) {
             sqsMessageThrottledCounter.increment();