chat/client/src/main/java/org/apidesign/demo/chat/ChatClient.java
branchNewChat
changeset 242 58596208d06d
parent 240 2d0750864a98
     1.1 --- a/chat/client/src/main/java/org/apidesign/demo/chat/ChatClient.java	Fri Apr 22 08:53:13 2016 +0200
     1.2 +++ b/chat/client/src/main/java/org/apidesign/demo/chat/ChatClient.java	Fri Apr 22 18:13:09 2016 +0200
     1.3 @@ -57,21 +57,23 @@
     1.4          Message msg = new Message();
     1.5          msg.setUser(m.getUser());
     1.6          msg.setComment(m.getComment());
     1.7 -        m.socket(m.getUrl(), new Query().assignPost(msg));
     1.8 +        m.socket(m.getUrl(), new Query().requestPost(msg));
     1.9      }
    1.10      
    1.11      static void cantChat(ChatModel model, Exception err) {
    1.12          model.getMsgs().add(new Message("System", err.getMessage(), 0));
    1.13      }
    1.14      
    1.15 -    
    1.16      @OnReceive(url = "{url}/chat", method = "WebSocket", data = Query.class, onError = "cantChat")
    1.17      static void socket(ChatModel m, Reply reply) {
    1.18          if (reply == null) {
    1.19              m.getMsgs().add(new Message("System", "Connected to server at " + m.getUrl() + "/chat!", 0));
    1.20 +            m.socket(m.getUrl(), new Query().requestAll(true).requestPost(null));
    1.21              return;
    1.22          }
    1.23 -        m.getMsgs().clear();
    1.24 +        if (reply.isAll()) {
    1.25 +            m.getMsgs().clear();
    1.26 +        }
    1.27          m.getMsgs().addAll(reply.getMessages());
    1.28      }
    1.29