Change queue type used in DeferredResultController

auready · Nov 23, 2012 · 3d10278 · 3d10278
1 parent 30c5200
commit 3d10278
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/main/java/org/springframework/samples/mvc/async/DeferredResultController.java b/src/main/java/org/springframework/samples/mvc/async/DeferredResultController.java
@@ -1,6 +1,7 @@
 package org.springframework.samples.mvc.async;
 
 import java.util.Queue;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.PriorityBlockingQueue;
 
 import org.springframework.scheduling.annotation.Scheduled;
@@ -15,11 +16,11 @@
 @RequestMapping("/async")
 public class DeferredResultController {
 
-	private final Queue<DeferredResult<String>> responseBodyQueue = new PriorityBlockingQueue<DeferredResult<String>>();
+	private final Queue<DeferredResult<String>> responseBodyQueue = new ConcurrentLinkedQueue<DeferredResult<String>>();
 
-	private final Queue<DeferredResult<ModelAndView>> mavQueue = new PriorityBlockingQueue<DeferredResult<ModelAndView>>();
+	private final Queue<DeferredResult<ModelAndView>> mavQueue = new ConcurrentLinkedQueue<DeferredResult<ModelAndView>>();
 
-	private final Queue<DeferredResult<String>> exceptionQueue = new PriorityBlockingQueue<DeferredResult<String>>();
+	private final Queue<DeferredResult<String>> exceptionQueue = new ConcurrentLinkedQueue<DeferredResult<String>>();
 
 
 	@RequestMapping("/deferred-result/response-body")