Tests: Java websockets tests.
This commit is contained in:
57
test/java/websockets_mirror/app.java
Normal file
57
test/java/websockets_mirror/app.java
Normal file
@@ -0,0 +1,57 @@
|
||||
import java.io.IOException;
|
||||
import java.nio.ByteBuffer;
|
||||
|
||||
import javax.websocket.OnMessage;
|
||||
import javax.websocket.OnOpen;
|
||||
import javax.websocket.PongMessage;
|
||||
import javax.websocket.Session;
|
||||
import javax.websocket.server.ServerEndpoint;
|
||||
|
||||
@ServerEndpoint("/")
|
||||
public class app {
|
||||
|
||||
@OnOpen
|
||||
public void onOpen(Session session) {
|
||||
session.setMaxTextMessageBufferSize(8388608);
|
||||
}
|
||||
|
||||
@OnMessage
|
||||
public void echoTextMessage(Session session, String msg) {
|
||||
try {
|
||||
if (session.isOpen()) {
|
||||
session.getBasicRemote().sendText(msg, true);
|
||||
}
|
||||
} catch (IOException e) {
|
||||
try {
|
||||
session.close();
|
||||
} catch (IOException e1) {
|
||||
// Ignore
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@OnMessage
|
||||
public void echoBinaryMessage(Session session, ByteBuffer bb) {
|
||||
try {
|
||||
if (session.isOpen()) {
|
||||
session.getBasicRemote().sendBinary(bb, true);
|
||||
}
|
||||
} catch (IOException e) {
|
||||
try {
|
||||
session.close();
|
||||
} catch (IOException e1) {
|
||||
// Ignore
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Process a received pong. This is a NO-OP.
|
||||
*
|
||||
* @param pm Ignored.
|
||||
*/
|
||||
@OnMessage
|
||||
public void echoPongMessage(PongMessage pm) {
|
||||
// NO-OP
|
||||
}
|
||||
}
|
||||
1469
test/test_java_websockets.py
Normal file
1469
test/test_java_websockets.py
Normal file
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user