chore: add asl

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

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.amazon.sns.messaging.lib.concurrent;
 
 import java.lang.reflect.Method;
@@ -14,11 +30,11 @@
 
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public final class ExecutorsProvider {
-  
+
   private static final Logger LOGGER = LoggerFactory.getLogger(ExecutorsProvider.class);
-  
+
   private static Supplier<ExecutorService> supplierExecutorService;
-  
+
   static {
     if (ExecutorsProvider.getJavaVersion() >= 21) {
       ExecutorsProvider.supplierExecutorService = ExecutorsProvider::getVirtualThreadExecutor;
@@ -28,35 +44,35 @@ public final class ExecutorsProvider {
       ExecutorsProvider.LOGGER.info("Java version is {}, using default thread executor", ExecutorsProvider.getJavaVersion());
     }
   }
-
+  
   public static ExecutorService getThreadExecutor() {
     return ExecutorsProvider.supplierExecutorService.get();
   }
-
+  
   @SneakyThrows
   private static ExecutorService getDefaultThreadExecutor() {
     return Executors.newSingleThreadExecutor();
   }
-
+  
   @SneakyThrows
   private static ExecutorService getVirtualThreadExecutor() {
     final Class<?> clazzThread = Executors.class;
     final Method ofVirtualMethod = clazzThread.getMethod("newVirtualThreadPerTaskExecutor");
     return ExecutorService.class.cast(ofVirtualMethod.invoke(null));
   }
-  
+
   private static int getJavaVersion() {
     String version = System.getProperty("java.version");
-
+    
     if (version.startsWith("1.")) {
       version = version.substring(2);
     }
-
+    
     final int dotPos = version.indexOf('.');
     final int dashPos = version.indexOf('-');
     final int endIndex = dotPos > -1 ? dotPos : dashPos > -1 ? dashPos : 1;
-
+    
     return Integer.parseInt(version.substring(0, endIndex));
   }
-
+  
 }

amazon-sns-java-messaging-lib-template/src/main/java/com/amazon/sns/messaging/lib/instrument/MBeanRegistrar.java

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.amazon.sns.messaging.lib.instrument;
 
 import java.lang.management.ManagementFactory;
@@ -11,27 +27,27 @@
 
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public final class MBeanRegistrar {
-
+  
   private static final MBeanServer BEAN_SERVER = ManagementFactory.getPlatformMBeanServer();
-
+  
   @SneakyThrows
   public static void registerMBean(final Object mbean, final String name) {
     final ObjectName objectName = new ObjectName(name);
-
+    
     if (!MBeanRegistrar.BEAN_SERVER.isRegistered(objectName)) {
       MBeanRegistrar.BEAN_SERVER.registerMBean(mbean, objectName);
     }
-    
-  }
 
+  }
+  
   @SneakyThrows
   public static void unregisterMBean(final String name) {
     final ObjectName objectName = new ObjectName(name);
-    
+
     if (MBeanRegistrar.BEAN_SERVER.isRegistered(objectName)) {
       MBeanRegistrar.BEAN_SERVER.unregisterMBean(objectName);
     }
-    
+
   }
-  
+
 }

amazon-sns-java-messaging-lib-template/src/main/java/com/amazon/sns/messaging/lib/instrument/RingBufferBlockingQueueJmx.java

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.amazon.sns.messaging.lib.instrument;
 
 import com.amazon.sns.messaging.lib.concurrent.RingBufferBlockingQueue;
@@ -6,37 +22,37 @@
 
 @RequiredArgsConstructor
 public class RingBufferBlockingQueueJmx implements RingBufferBlockingQueueJmxMBean {
-
+  
   private final RingBufferBlockingQueue<?> ringBufferBlockingQueue;
-
+  
   @Override
   public int capacity() {
-    return this.ringBufferBlockingQueue.capacity();
+    return ringBufferBlockingQueue.capacity();
   }
-
+  
   @Override
   public int size() {
-    return this.ringBufferBlockingQueue.size();
+    return ringBufferBlockingQueue.size();
   }
-
+  
   @Override
   public boolean isEmpty() {
-    return this.ringBufferBlockingQueue.isEmpty();
+    return ringBufferBlockingQueue.isEmpty();
   }
-
+  
   @Override
   public boolean isFull() {
-    return this.ringBufferBlockingQueue.isFull();
+    return ringBufferBlockingQueue.isFull();
   }
-
+  
   @Override
   public long writeSequence() {
-    return this.ringBufferBlockingQueue.writeSequence();
+    return ringBufferBlockingQueue.writeSequence();
   }
-
+  
   @Override
   public long readSequence() {
-    return this.ringBufferBlockingQueue.readSequence();
+    return ringBufferBlockingQueue.readSequence();
   }
-
+  
 }

amazon-sns-java-messaging-lib-template/src/main/java/com/amazon/sns/messaging/lib/instrument/RingBufferBlockingQueueJmxMBean.java

@@ -1,17 +1,33 @@
+/*
+ * Copyright 2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.amazon.sns.messaging.lib.instrument;
 
 public interface RingBufferBlockingQueueJmxMBean {
-
+  
   int capacity();
-
+  
   int size();
-
+  
   boolean isEmpty();
-
+  
   boolean isFull();
-
+  
   long writeSequence();
-
+  
   long readSequence();
-
+  
 }

amazon-sns-java-messaging-lib-template/src/test/java/com/amazon/sns/messaging/lib/core/ListenableFutureRegistryTest.java

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.amazon.sns.messaging.lib.core;
 
 import static org.hamcrest.CoreMatchers.notNullValue;