From ad5389cf6d7b468ecd4fe6d2936b28740c26fb4b Mon Sep 17 00:00:00 2001
From: Nikhil Khatwani <nkhatwani85@gmail.com>
Date: Wed, 2 May 2018 14:39:57 +0530
Subject: [PATCH] Changes for BAEL-1657

---
 .../servlets/DeferredResultController.java    | 71 +++++++++++++++++++
 1 file changed, 71 insertions(+)
 create mode 100644 spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java

diff --git a/spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java b/spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java
new file mode 100644
index 0000000000..c43b0e6dc0
--- /dev/null
+++ b/spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java
@@ -0,0 +1,71 @@
+package com.baeldung.servlets;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.context.request.async.DeferredResult;
+
+@RestController
+public class DeferredResultController {
+
+	private final static Logger LOG = LoggerFactory.getLogger(DeferredResultController.class);
+
+	@GetMapping("/async-deferredresult")
+	public DeferredResult<ResponseEntity<?>> handleReqDefResult(Model model) {
+		LOG.info("Received async-deferredresult request");
+		DeferredResult<ResponseEntity<?>> output = new DeferredResult<>();
+		new Thread(() -> {
+			LOG.info("Processing in separate thread");
+			output.setResult(ResponseEntity.ok("ok"));
+		}).start();
+		LOG.info("servlet thread freed");
+		return output;
+	}
+
+	public DeferredResult<ResponseEntity<?>> handleReqWithTimeouts(Model model) {
+		LOG.info("Received async request with a configured timeout");
+		DeferredResult<ResponseEntity<?>> deferredResult = new DeferredResult<>(500l);
+		deferredResult.onTimeout(new Runnable() {
+			@Override
+			public void run() {
+				deferredResult.setErrorResult(
+						ResponseEntity.status(HttpStatus.REQUEST_TIMEOUT).body("Request timeout occurred."));
+			}
+		});
+
+		new Thread(() -> {
+			LOG.info("Processing in separate thread");
+			try {
+				Thread.sleep(600l);
+				deferredResult.setResult(ResponseEntity.ok("ok"));
+			} catch (InterruptedException e) {
+				LOG.info("Request processing interrupted");
+				deferredResult.setErrorResult(ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
+						.body("INTERNAL_SERVER_ERROR occurred."));
+			}
+
+		}).start();
+		LOG.info("servlet thread freed");
+		return deferredResult;
+	}
+
+	public DeferredResult<ResponseEntity<?>> handleAsyncFailedRequest(Model model) {
+		DeferredResult<ResponseEntity<?>> deferredResult = new DeferredResult<>();
+		new Thread(() -> {
+			try {
+				// Exception occurred in processing
+				throw new Exception();
+			} catch (Exception e) {
+				LOG.info("Request processing failed");
+				deferredResult.setErrorResult(ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
+						.body("INTERNAL_SERVER_ERROR occurred."));
+			}
+		}).start();
+		return deferredResult;
+	}
+
+}