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