36 lines
1.2 KiB
Java
36 lines
1.2 KiB
Java
package com.baeldung.web;
|
|
|
|
import com.baeldung.Constants;
|
|
import java.util.Date;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.Executors;
|
|
import org.springframework.http.HttpStatus;
|
|
import org.springframework.http.MediaType;
|
|
import org.springframework.http.ResponseEntity;
|
|
import org.springframework.stereotype.Controller;
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;
|
|
|
|
@Controller
|
|
public class ResponseBodyEmitterController {
|
|
|
|
@GetMapping(Constants.API_RBE)
|
|
public ResponseEntity<ResponseBodyEmitter> handleRbe() {
|
|
ResponseBodyEmitter emitter = new ResponseBodyEmitter();
|
|
ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
|
|
|
|
nonBlockingService.execute(() -> {
|
|
try {
|
|
emitter.send(Constants.API_RBE_MSG + " @ " + new Date(), MediaType.TEXT_PLAIN);
|
|
emitter.complete();
|
|
} catch (Exception ex) {
|
|
System.out.println(Constants.GENERIC_EXCEPTION);
|
|
emitter.completeWithError(ex);
|
|
}
|
|
});
|
|
|
|
return new ResponseEntity(emitter, HttpStatus.OK);
|
|
}
|
|
|
|
}
|