Cleaned up logs and logstash extensions

kumuluz · Dec 5, 2022 · 406a221 · 406a221
1 parent 07c90be
commit 406a221
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 14 deletions.
diff --git a/logs/src/main/java/com/kumuluz/ee/metrics/logs/LogsInitiator.java b/logs/src/main/java/com/kumuluz/ee/metrics/logs/LogsInitiator.java
@@ -43,7 +43,7 @@ public class LogsInitiator {
 
     private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
 
-    private ScheduledFuture handle;
+    private ScheduledFuture<?> handle;
 
     private void initialiseBean(@Observes @Initialized(ApplicationScoped.class) Object init) {
         ConfigurationUtil configurationUtil = ConfigurationUtil.getInstance();

diff --git a/logs/src/main/java/com/kumuluz/ee/metrics/logs/LogsSender.java b/logs/src/main/java/com/kumuluz/ee/metrics/logs/LogsSender.java
@@ -41,9 +41,9 @@
 public class LogsSender implements Runnable {
 
     private static final Logger log = Logger.getLogger(LogsSender.class.getName());
-    private Level level;
+    private final Level level;
 
-    private ObjectMapper mapper;
+    private final ObjectMapper mapper;
 
     public LogsSender(String level) {
         this.mapper = (new ObjectMapper()).registerModule(new MetricsModule(false));

diff --git a/logstash/src/main/java/com/kumuluz/ee/metrics/KumuluzEELogstashReporter.java b/logstash/src/main/java/com/kumuluz/ee/metrics/KumuluzEELogstashReporter.java
@@ -38,14 +38,14 @@ public class KumuluzEELogstashReporter {
     private static final Logger log = Logger.getLogger(KumuluzEELogstashReporter.class.getName());
 
     private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
-    private ScheduledFuture handle;
+    private ScheduledFuture<?> handle;
 
-    private String address;
-    private int port;
-    private long periodSeconds;
+    private final String address;
+    private final int port;
+    private final long periodSeconds;
 
-    private int startRetryDelay;
-    private int maxRetryDelay;
+    private final int startRetryDelay;
+    private final int maxRetryDelay;
 
     public KumuluzEELogstashReporter(String address, int port, long periodSeconds, int startRetryDelay,
                                      int maxRetryDelay) {

diff --git a/logstash/src/main/java/com/kumuluz/ee/metrics/LogstashSender.java b/logstash/src/main/java/com/kumuluz/ee/metrics/LogstashSender.java
@@ -47,15 +47,15 @@ public class LogstashSender implements Runnable {
 
     private static final Logger log = Logger.getLogger(LogstashSender.class.getName());
 
-    private String address;
-    private int port;
-    private ObjectMapper mapper;
+    private final String address;
+    private final int port;
+    private final ObjectMapper mapper;
 
     private Socket socket;
     private BufferedOutputStream outputStream = null;
 
-    private int startRetryDelay;
-    private int maxRetryDelay;
+    private final int startRetryDelay;
+    private final int maxRetryDelay;
     private int currentRetryDelay;
 
     public LogstashSender(String address, int port, int startRetryDelay, int maxRetryDelay) {