refactor: use lambdas for updaters

OpenLiberty · Jan 17, 2025 · a97a7b0 · a97a7b0
1 parent 8fd34b6
commit a97a7b0
Showing 1 changed file with 5 additions and 27 deletions.
diff --git a/...essaging.msgstore/src/com/ibm/ws/sib/msgstore/persistence/dispatcher/DispatcherState.java b/...essaging.msgstore/src/com/ibm/ws/sib/msgstore/persistence/dispatcher/DispatcherState.java
@@ -21,26 +21,10 @@
 import com.ibm.ws.sib.msgstore.persistence.dispatcher.StateUtils.StateUpdater;
 
 final class DispatcherState {
-    static final StateUpdater<DispatcherState> updaterForStart = new StateUpdater<DispatcherState>() {
-        public DispatcherState update(DispatcherState currentState) {
-            return currentState.startRequested().running(true);
-        }
-    };
-    static final StateUpdater<DispatcherState> updaterForStopped = new StateUpdater<DispatcherState>() {
-        public DispatcherState update(DispatcherState currentState) {
-            return currentState.running(false);
-        }
-    };
-    static final StateUpdater<DispatcherState> updaterForErrorOccurred = new StateUpdater<DispatcherState>() {
-        public DispatcherState update(DispatcherState currentState) {
-            return currentState.addThreadWriteError();
-        }
-    };
-    static final StateUpdater<DispatcherState> updaterForErrorCleared = new StateUpdater<DispatcherState>() {
-        public DispatcherState update(DispatcherState currentState) {
-            return currentState.clearThreadWriteError();
-        }
-    };
+    static final StateUpdater<DispatcherState> updaterForStart = state -> state.startRequested().running(true);
+    static final StateUpdater<DispatcherState> updaterForStopped = state -> state.running(false);
+    static final StateUpdater<DispatcherState> updaterForErrorOccurred = DispatcherState::addThreadWriteError;
+    static final StateUpdater<DispatcherState> updaterForErrorCleared = DispatcherState::clearThreadWriteError;
 
     public static final class StopRequesterInfo extends Throwable {
         private static final long serialVersionUID = 1L;
@@ -52,13 +36,7 @@ public StopRequesterInfo(Throwable requester) {
     }
 
     static StateUpdater<DispatcherState> getUpdaterForStopRequested(final Throwable requester) {
-        return new StateUpdater<DispatcherState>() {
-            @Override
-            public DispatcherState update(DispatcherState currentState) {
-                if (!currentState.isRunning) return currentState;
-                return currentState.stopRequested(new StopRequesterInfo(requester));
-            }
-        };
+        return state -> state.isRunning ? state.stopRequested(new StopRequesterInfo(requester)) : state;
     }
 
     // Flag set to indicate whether dispatcher is running.