feat: house keeping

Signed-off-by: Marcos Tischer Vallim <tischer@gmail.com>

Author: mvallim

amazon-sns-java-messaging-lib-template/src/main/java/com/amazon/sns/messaging/lib/concurrent/ExecutorsProvider.java

@@ -37,25 +37,25 @@ public final class ExecutorsProvider {
 
   static {
     if (ExecutorsProvider.getJavaVersion() >= 21) {
-      ExecutorsProvider.supplierExecutorService = ExecutorsProvider::getVirtualThreadExecutor;
+      ExecutorsProvider.supplierExecutorService = ExecutorsProvider::getVirtualExecutorService;
       ExecutorsProvider.LOGGER.info("Java version is {}, using virtual thread executor", ExecutorsProvider.getJavaVersion());
     } else {
-      ExecutorsProvider.supplierExecutorService = ExecutorsProvider::getDefaultThreadExecutor;
+      ExecutorsProvider.supplierExecutorService = ExecutorsProvider::getDefaultExecutorService;
       ExecutorsProvider.LOGGER.info("Java version is {}, using default thread executor", ExecutorsProvider.getJavaVersion());
     }
   }
 
-  public static ExecutorService getThreadExecutor() {
+  public static ExecutorService getExecutorService() {
     return ExecutorsProvider.supplierExecutorService.get();
   }
 
   @SneakyThrows
-  private static ExecutorService getDefaultThreadExecutor() {
+  private static ExecutorService getDefaultExecutorService() {
     return Executors.newSingleThreadExecutor();
   }
 
   @SneakyThrows
-  private static ExecutorService getVirtualThreadExecutor() {
+  private static ExecutorService getVirtualExecutorService() {
     final Class<?> clazzThread = Executors.class;
     final Method ofVirtualMethod = clazzThread.getMethod("newVirtualThreadPerTaskExecutor");
     return ExecutorService.class.cast(ofVirtualMethod.invoke(null));

amazon-sns-java-messaging-lib-template/src/test/java/com/amazon/sns/messaging/lib/concurrent/RingBufferBlockingQueueTest.java

@@ -41,7 +41,7 @@ class RingBufferBlockingQueueTest {
 
   @Test
   void testSuccess() {
-    final ExecutorService producer = ExecutorsProvider.getThreadExecutor();
+    final ExecutorService producer = ExecutorsProvider.getExecutorService();
 
     final ScheduledExecutorService consumer = Executors.newSingleThreadScheduledExecutor(ThreadFactoryProvider.getThreadFactory());
 
@@ -90,9 +90,9 @@ void testSuccess() {
   void testSuccessWhenIsEmpty() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
 
-    final ExecutorService producer = ExecutorsProvider.getThreadExecutor();
+    final ExecutorService producer = ExecutorsProvider.getExecutorService();
 
-    final ExecutorService consumer = ExecutorsProvider.getThreadExecutor();
+    final ExecutorService consumer = ExecutorsProvider.getExecutorService();
 
     consumer.submit(() -> {
       assertThat(ringBlockingQueue.take().getValue(), is(0));
@@ -119,9 +119,9 @@ void testSuccessWhenIsEmpty() {
   void testSuccessWhenIsFull() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>(1);
 
-    final ExecutorService producer = ExecutorsProvider.getThreadExecutor();
+    final ExecutorService producer = ExecutorsProvider.getExecutorService();
 
-    final ExecutorService consumer = ExecutorsProvider.getThreadExecutor();
+    final ExecutorService consumer = ExecutorsProvider.getExecutorService();
 
     producer.submit(() -> {
       ringBlockingQueue.put(RequestEntry.<Integer>builder().withValue(0).build());

amazon-sns-java-messaging-lib-v1/src/main/java/com/amazon/sns/messaging/lib/core/AmazonSnsTemplate.java

@@ -41,7 +41,7 @@ private AmazonSnsTemplate(
       final ObjectMapper objectMapper,
       final UnaryOperator<PublishBatchRequest> publishDecorator) {
     super(
-      new AmazonSnsProducer<>(pendingRequests, topicRequests, ExecutorsProvider.getThreadExecutor()),
+      new AmazonSnsProducer<>(pendingRequests, topicRequests, ExecutorsProvider.getExecutorService()),
       new AmazonSnsConsumer<>(amazonSnsClient, topicProperty, objectMapper, pendingRequests, topicRequests, AbstractAmazonSnsTemplate.getAmazonSnsThreadPoolExecutor(topicProperty), publishDecorator)
     );
   }

amazon-sns-java-messaging-lib-v2/src/main/java/com/amazon/sns/messaging/lib/core/AmazonSnsTemplate.java

@@ -42,7 +42,7 @@ private AmazonSnsTemplate(
       final ObjectMapper objectMapper,
       final UnaryOperator<PublishBatchRequest> publishDecorator) {
     super(
-      new AmazonSnsProducer<>(pendingRequests, topicRequests, ExecutorsProvider.getThreadExecutor()),
+      new AmazonSnsProducer<>(pendingRequests, topicRequests, ExecutorsProvider.getExecutorService()),
       new AmazonSnsConsumer<>(amazonSnsClient, topicProperty, objectMapper, pendingRequests, topicRequests, AbstractAmazonSnsTemplate.getAmazonSnsThreadPoolExecutor(topicProperty), publishDecorator)
     );
   }