Added a timeout for message updating

m0ver · web-flow · commit 4871af6f7638 · 2017-07-24T01:12:12.000-04:00
diff --git a/src/tinystruct/examples/talk.java b/src/tinystruct/examples/talk.java
@@ -130,7 +130,9 @@ public final String update(final String sessionId) throws ApplicationException,
     Queue<Builder> messages = this.list.get(sessionId);
     // If there is a new message, then return it directly
     if((message = messages.poll()) != null) return message.toString();
-    while((message = messages.poll()) == null) {
+    
+    long startTime = System.currentTimeMillis();
+    while((message = messages.poll()) == null && (System.currentTimeMillis()-startTime) <= 10000) {
       ;
     }
     return message.toString();

Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,9 @@ public final String update(final String sessionId) throws ApplicationException,`
`130`	`130`	`Queue<Builder> messages = this.list.get(sessionId);`
`131`	`131`	`// If there is a new message, then return it directly`
`132`	`132`	`if((message = messages.poll()) != null) return message.toString();`
`133`		`- while((message = messages.poll()) == null) {`
	`133`	`+`
	`134`	`+ long startTime = System.currentTimeMillis();`
	`135`	`+ while((message = messages.poll()) == null && (System.currentTimeMillis()-startTime) <= 10000) {`
`134`	`136`	`;`
`135`	`137`	`}`
`136`	`138`	`return message.toString();`