AlphaX/qortal
1
0
Fork 0
forked from Qortal/qortal
Code Issues Pull Requests Projects Releases Wiki Activity

Add websocket error handler support

Browse Source
This commit is contained in:
catbref 2020-07-27 10:16:21 +01:00
parent eb27b0d3e2
commit 340d6dfc8d
4 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/qortal/api/websocket/ActiveChatsWebSocket.java
View File

@ -9,6 +9,7 @@ import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.WebSocketException; import org.eclipse.jetty.websocket.api.WebSocketException;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket; import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.eclipse.jetty.websocket.servlet.WebSocketServlet; import org.eclipse.jetty.websocket.servlet.WebSocketServlet;
@ -53,6 +54,10 @@ public class ActiveChatsWebSocket extends WebSocketServlet implements ApiWebSock
ChatNotifier.getInstance().deregister(session); ChatNotifier.getInstance().deregister(session);
} }
@OnWebSocketError
public void onWebSocketError(Session session, Throwable throwable) {
}
@OnWebSocketMessage @OnWebSocketMessage
public void onWebSocketMessage(Session session, String message) { public void onWebSocketMessage(Session session, String message) {
} }

5
src/main/java/org/qortal/api/websocket/AdminStatusWebSocket.java
View File

@ -8,6 +8,7 @@ import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.WebSocketException; import org.eclipse.jetty.websocket.api.WebSocketException;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket; import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.eclipse.jetty.websocket.servlet.WebSocketServlet; import org.eclipse.jetty.websocket.servlet.WebSocketServlet;
@ -42,6 +43,10 @@ public class AdminStatusWebSocket extends WebSocketServlet implements ApiWebSock
StatusNotifier.getInstance().deregister(session); StatusNotifier.getInstance().deregister(session);
} }
@OnWebSocketError
public void onWebSocketError(Session session, Throwable throwable) {
}
@OnWebSocketMessage @OnWebSocketMessage
public void onWebSocketMessage(Session session, String message) { public void onWebSocketMessage(Session session, String message) {
} }

5
src/main/java/org/qortal/api/websocket/BlocksWebSocket.java
View File

@ -8,6 +8,7 @@ import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.WebSocketException; import org.eclipse.jetty.websocket.api.WebSocketException;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket; import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.eclipse.jetty.websocket.servlet.WebSocketServlet; import org.eclipse.jetty.websocket.servlet.WebSocketServlet;
@ -40,6 +41,10 @@ public class BlocksWebSocket extends WebSocketServlet implements ApiWebSocket {
BlockNotifier.getInstance().deregister(session); BlockNotifier.getInstance().deregister(session);
} }
@OnWebSocketError
public void onWebSocketError(Session session, Throwable throwable) {
}
@OnWebSocketMessage @OnWebSocketMessage
public void onWebSocketMessage(Session session, String message) { public void onWebSocketMessage(Session session, String message) {
// We're expecting either a base58 block signature or an integer block height // We're expecting either a base58 block signature or an integer block height

5
src/main/java/org/qortal/api/websocket/ChatMessagesWebSocket.java
View File

@ -11,6 +11,7 @@ import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.WebSocketException; import org.eclipse.jetty.websocket.api.WebSocketException;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage; import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket; import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.eclipse.jetty.websocket.servlet.WebSocketServlet; import org.eclipse.jetty.websocket.servlet.WebSocketServlet;
@ -90,6 +91,10 @@ public class ChatMessagesWebSocket extends WebSocketServlet implements ApiWebSoc
ChatNotifier.getInstance().deregister(session); ChatNotifier.getInstance().deregister(session);
} }
@OnWebSocketError
public void onWebSocketError(Session session, Throwable throwable) {
}
@OnWebSocketMessage @OnWebSocketMessage
public void onWebSocketMessage(Session session, String message) { public void onWebSocketMessage(Session session, String message) {
} }