1.1 --- a/chat/server/src/main/java/org/apidesign/demo/chat/server/ChatServerResource.java Fri Apr 22 05:56:47 2016 +0200
1.2 +++ b/chat/server/src/main/java/org/apidesign/demo/chat/server/ChatServerResource.java Fri Apr 22 08:53:13 2016 +0200
1.3 @@ -24,27 +24,14 @@
1.4 package org.apidesign.demo.chat.server;
1.5
1.6 import java.util.ArrayList;
1.7 -import java.util.IdentityHashMap;
1.8 import java.util.List;
1.9 -import java.util.Map;
1.10 import java.util.logging.Logger;
1.11 -import javax.inject.Singleton;
1.12 -import javax.ws.rs.Consumes;
1.13 -import javax.ws.rs.DefaultValue;
1.14 -import javax.ws.rs.GET;
1.15 -import javax.ws.rs.POST;
1.16 -import javax.ws.rs.Path;
1.17 -import javax.ws.rs.Produces;
1.18 -import javax.ws.rs.QueryParam;
1.19 -import javax.ws.rs.container.AsyncResponse;
1.20 -import javax.ws.rs.container.Suspended;
1.21 -import javax.ws.rs.core.MediaType;
1.22 import org.apidesign.demo.chat.shared.Message;
1.23 -import org.apidesign.demo.chat.shared.Query;
1.24 +import org.glassfish.grizzly.websockets.WebSocket;
1.25 +import org.glassfish.grizzly.websockets.WebSocketApplication;
1.26
1.27 /** Server side of the chat application.*/
1.28 -@Path("/chat/") @Singleton
1.29 -public final class ChatServerResource {
1.30 +public final class ChatServerResource extends WebSocketApplication {
1.31 private static final Logger LOG = Logger.getLogger(ChatServerResource.class.getName());
1.32 private static final long started = System.currentTimeMillis() - 10;
1.33
1.34 @@ -56,7 +43,9 @@
1.35 welcome.setSince(10);
1.36 msgs.add(welcome);
1.37 }
1.38 -
1.39 +
1.40 +
1.41 +/*
1.42 private final Map<AsyncResponse, Long> awaiting = new IdentityHashMap<>();
1.43
1.44 @Produces(MediaType.APPLICATION_JSON)
1.45 @@ -100,4 +89,10 @@
1.46 handleAwaiting(msg.getSince());
1.47 return msg;
1.48 }
1.49 +*/
1.50 +
1.51 + @Override
1.52 + public void onMessage(WebSocket socket, String text) {
1.53 + super.onMessage(socket, text);
1.54 + }
1.55 }