Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reworking websocket chat example to not forward disconnect to other chat members. (oops)

This commit is contained in:
Joakim Erdfelt 2012-08-08 08:34:29 -07:00
parent 1a62c5ded6
commit 1a62b2a780
1 changed files with 22 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
test-jetty-webapp/src/main/java/com/acme/WebSocketChatServlet.java
View File

@ -82,14 +82,7 @@ public class WebSocketChatServlet extends WebSocketServlet implements WebSocketC
@OnWebSocketMessage
public void onMessage(String data)
{
if (!connection.isOpen())
{
// Nothing to do, connection is already closed.
// Due to the nature of async communications, this is possible.
return;
}
if (data.indexOf("disconnect") >= 0)
if (data.contains("disconnect"))
{
try
{
@ -99,30 +92,29 @@ public class WebSocketChatServlet extends WebSocketServlet implements WebSocketC
{
LOG.warn(e);
}
return;
}
else
{
ListIterator<ChatWebSocket> iter = members.listIterator();
while (iter.hasNext())
{
ChatWebSocket member = iter.next();
// Test is member is now disonnected
if (!member.connection.isOpen())
{
iter.remove();
continue;
}
try
{
// Async write the message back.
member.connection.write(null,new FutureCallback<>(),data);
}
catch (IOException e)
{
LOG.warn(e);
}
ListIterator<ChatWebSocket> iter = members.listIterator();
while (iter.hasNext())
{
ChatWebSocket member = iter.next();
// Test if member is now disconnected
if (!member.connection.isOpen())
{
iter.remove();
continue;
}
try
{
// Async write the message back.
member.connection.write(null,new FutureCallback<>(),data);
}
catch (IOException e)
{
LOG.warn(e);
}
}
}