iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Bael 1555 - Improve Example (#4852) 

* BAEL-1555

* Corrected indents and spacing

* RequestMapping to GetMapping

* Improved Performance For Concurrent Users
This commit is contained in:
Adam InTae Gerard 2018-07-30 22:41:59 -07:00 committed by Grzegorz Piwowarek
parent aabbd93fcf
commit a1213549f3
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spring-5-mvc/src/main/java/com/baeldung/web/ResponseBodyEmitterController.java
View File

@ -13,11 +13,11 @@ import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter
@Controller @Controller
public class ResponseBodyEmitterController { public class ResponseBodyEmitterController {
private ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
@GetMapping(Constants.API_RBE) @GetMapping(Constants.API_RBE)
public ResponseEntity<ResponseBodyEmitter> handleRbe() { public ResponseEntity<ResponseBodyEmitter> handleRbe() {
ResponseBodyEmitter emitter = new ResponseBodyEmitter(); ResponseBodyEmitter emitter = new ResponseBodyEmitter();
ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
nonBlockingService.execute(() -> { nonBlockingService.execute(() -> {
try { try {

2
spring-5-mvc/src/main/java/com/baeldung/web/SseEmitterController.java
View File

@ -10,12 +10,12 @@ import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
@Controller @Controller
public class SseEmitterController { public class SseEmitterController {
private ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
@GetMapping(Constants.API_SSE) @GetMapping(Constants.API_SSE)
public SseEmitter handleSse() { public SseEmitter handleSse() {
SseEmitter emitter = new SseEmitter(); SseEmitter emitter = new SseEmitter();
ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
nonBlockingService.execute(() -> { nonBlockingService.execute(() -> {
try { try {
emitter.send(Constants.API_SSE_MSG + " @ " + new Date()); emitter.send(Constants.API_SSE_MSG + " @ " + new Date());