chat/server/src/main/java/org/apidesign/demo/chat/server/ChatServerResource.java
branchNewChat
changeset 240 2d0750864a98
parent 238 a0f15cb8c730
child 241 6a59fdb91011
     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  }