PushReceiverでErrorコマンド受診時に再接続するよう修正

montsuqi · Feb 19, 2018 · 1576a50 · 1576a50
1 parent 82becd2
commit 1576a50
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/org/montsuqi/monsiaj/client/PushReceiver.java b/src/main/java/org/montsuqi/monsiaj/client/PushReceiver.java
@@ -154,6 +154,9 @@ public void run() {
 
     private class PusherPingTimeout extends Exception {
     }
+
+    private class PusherErrorCommand extends Exception {
+    }    
 
     @WebSocket
     public class PusherWebSocket {
@@ -197,7 +200,7 @@ public void onConnect(Session session) {
         }
 
         @OnWebSocketMessage
-        public void onMessage(String message) {
+        public void onMessage(String message) throws PusherErrorCommand {
             logger.info("---- onMessage");
             logger.info(message);
             messageHandler(message);
@@ -246,7 +249,7 @@ public void sendPing() throws PusherPingTimeout {
         }
     }
 
-    private void messageHandler(String message) {
+    private void messageHandler(String message) throws PusherErrorCommand {
         JSONObject obj = new JSONObject(message);
         switch (obj.getString("command")) {
             case "subscribed":
@@ -260,6 +263,8 @@ private void messageHandler(String message) {
                     logger.error(ex, ex);
                 }
                 break;
+            case "error":
+                throw new PusherErrorCommand();
         }
     }