diff --git a/spring-5-mvc/src/main/java/com/baeldung/web/ResponseBodyEmitterController.java b/spring-5-mvc/src/main/java/com/baeldung/web/ResponseBodyEmitterController.java
index 4af8eb9bd3..ff1fb87393 100644
--- a/spring-5-mvc/src/main/java/com/baeldung/web/ResponseBodyEmitterController.java
+++ b/spring-5-mvc/src/main/java/com/baeldung/web/ResponseBodyEmitterController.java
@@ -13,11 +13,11 @@ import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter
 
 @Controller
 public class ResponseBodyEmitterController {
+    private ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
 
     @GetMapping(Constants.API_RBE)
     public ResponseEntity<ResponseBodyEmitter> handleRbe() {
         ResponseBodyEmitter emitter = new ResponseBodyEmitter();
-        ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
 
             nonBlockingService.execute(() -> {
                 try {
diff --git a/spring-5-mvc/src/main/java/com/baeldung/web/SseEmitterController.java b/spring-5-mvc/src/main/java/com/baeldung/web/SseEmitterController.java
index 390178aaef..944aec2559 100644
--- a/spring-5-mvc/src/main/java/com/baeldung/web/SseEmitterController.java
+++ b/spring-5-mvc/src/main/java/com/baeldung/web/SseEmitterController.java
@@ -10,12 +10,12 @@ import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 @Controller
 public class SseEmitterController {
+    private ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
 
     @GetMapping(Constants.API_SSE)
     public SseEmitter handleSse() {
         SseEmitter emitter = new SseEmitter();
 
-        ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
         nonBlockingService.execute(() -> {
             try {
                 emitter.send(Constants.API_SSE_MSG + " @ " + new Date());