Improve latest commit

pop-team · Oct 6, 2017 · 0a4f9c8 · 0a4f9c8
1 parent 1623731
commit 0a4f9c8
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/workspace/popjava/src/popjava/broker/Broker.java b/workspace/popjava/src/popjava/broker/Broker.java
@@ -843,13 +843,10 @@ public POPAccessPoint getAccessPoint() {
 	public void treatRequests() throws InterruptedException { 
 		setState(State.Running);
 		while (getState() == State.Running) {
-			for (ComboxServer comboxServer : comboxServers) {
-				Request request = comboxServer.getRequestQueue().peek(REQUEST_QUEUE_TIMEOUT_MS,
-						TimeUnit.MILLISECONDS);
-
-				if (request != null) {
-					serveRequest(request);
-				}
+			Request request = requestQueue.peek(REQUEST_QUEUE_TIMEOUT_MS, TimeUnit.MILLISECONDS);
+
+			if (request != null) {
+				serveRequest(request);
 			}
 		}
 		LogWriter.writeDebugInfo("[Broker] Close broker "+popInfo.getClassName());