dev

src/main/java/com/its/op/scheduler/ItsOpSigPhaseListener.java

@@ -33,8 +33,7 @@ public class ItsOpSigPhaseListener {
     public void init() {
         this.mapper = new ObjectMapper();
 
-        BasicThreadFactory factory = new BasicThreadFactory.Builder()
-                .namingPattern("signal-phase-listener-%d").build();
+        BasicThreadFactory factory = new BasicThreadFactory.Builder().namingPattern("signal-phase-listener-%d").build();
         this.executorService = Executors.newSingleThreadExecutor(factory);
         this.executorService.execute(new Runnable() {
             @Override
@@ -44,13 +43,14 @@ public class ItsOpSigPhaseListener {
                     long delayMillis = doJob();
                     try {
                         Thread.sleep(delayMillis);
-                    } catch (InterruptedException e) {
-                        log.error("{}", e.getMessage());
+                    } catch (Exception e) {
+                        log.error("--RUN: ItsOpSigPhaseListener. Exception, {}", e.getMessage());
                     }
                 }
                 log.info("--END: ItsOpSigPhaseListener.");
             }
         });
+
         this.executorService.shutdown();
     }