FilesExpand file tree

 master

/

WebSocketAdapter.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

133 lines (119 loc) · 4.63 KB

 master

/

WebSocketAdapter.java

Copy path

Top

File metadata and controls

• Code
• Blame

133 lines (119 loc) · 4.63 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

package org.java_websocket;

import org.java_websocket.drafts.Draft;

import org.java_websocket.exeptions.InvalidDataException;

import org.java_websocket.framing.Framedata;

import org.java_websocket.framing.Framedata.Opcode;

import org.java_websocket.framing.FramedataImpl1;

import org.java_websocket.handshake.ClientHandshake;

import org.java_websocket.handshake.HandshakeImpl1Server;

import org.java_websocket.handshake.Handshakedata;

import org.java_websocket.handshake.ServerHandshake;

import org.java_websocket.handshake.ServerHandshakeBuilder;

public abstract class WebSocketAdapter implements WebSocketListener {

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see org.java_websocket.WebSocketListener#onWebsocketHandshakeReceivedAsServer(WebSocket, Draft, ClientHandshake)

*/

@Override

public ServerHandshakeBuilder onWebsocketHandshakeReceivedAsServer( WebSocket conn, Draft draft, ClientHandshake request ) throws InvalidDataException {

return new HandshakeImpl1Server();

}

/**

* This default implementation does not do anything which will cause connections to be accepted. Go ahead and overwrite it.

*

* @see org.java_websocket.WebSocketListener#onWebsocketHandshakeReceivedAsClient(WebSocket, ClientHandshake, ServerHandshake)

*/

@Override

public void onWebsocketHandshakeReceivedAsClient( WebSocket conn, ClientHandshake request, ServerHandshake response ) throws InvalidDataException {

}

/**

* This default implementation does not do anything which will cause the connections to always progress.

*

* @see org.java_websocket.WebSocketListener#onWebsocketHandshakeSentAsClient(WebSocket, ClientHandshake)

*/

@Override

public void onWebsocketHandshakeSentAsClient( WebSocket conn, ClientHandshake request ) throws InvalidDataException {

}

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see org.java_websocket.WebSocketListener#onWebsocketMessage(WebSocket, String)

*/

@Override

public void onWebsocketMessage( WebSocket conn, String message ) {

}

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see @see org.java_websocket.WebSocketListener#onWebsocketOpen(WebSocket, Handshakedata)

*/

@Override

public void onWebsocketOpen( WebSocket conn, Handshakedata handshake ) {

}

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see @see org.java_websocket.WebSocketListener#onWebsocketClose(WebSocket, int, String, boolean)

*/

@Override

public void onWebsocketClose( WebSocket conn, int code, String reason, boolean remote ) {

}

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see @see org.java_websocket.WebSocketListener#onWebsocketMessage(WebSocket, byte[])

*/

@Override

public void onWebsocketMessage( WebSocket conn, byte[] blob ) {

}

/**

* This default implementation will send a pong in response to the received ping.

* The pong frame will have the same payload as the ping frame.

*

* @see @see org.java_websocket.WebSocketListener#onWebsocketPing(WebSocket, Framedata)

*/

@Override

public void onWebsocketPing( WebSocket conn, Framedata f ) {

FramedataImpl1 resp = new FramedataImpl1( f );

resp.setOptcode( Opcode.PONG );

try {

conn.sendFrame( resp );

} catch ( InterruptedException e ) {

e.printStackTrace();

}

}

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see @see org.java_websocket.WebSocketListener#onWebsocketPong(WebSocket, Framedata)

*/

@Override

public void onWebsocketPong( WebSocket conn, Framedata f ) {

}

/**

* Gets the XML string that should be returned if a client requests a Flash

* security policy.

*

* The default implementation allows access from all remote domains, but

* only on the port that this WebSocketServer is listening on.

*

* This is specifically implemented for gitime's WebSocket client for Flash:

* http://github.com/gimite/web-socket-js

*

* @return An XML String that comforms to Flash's security policy. You MUST

* not include the null char at the end, it is appended automatically.

*/

@Override

public String getFlashPolicy( WebSocket conn ) {

return "<cross-domain-policy><allow-access-from domain=\"*\" to-ports=\"" + conn.getLocalSocketAddress().getPort() + "\" /></cross-domain-policy>\0";

}

/**

* This default implementation does not do anything. Go ahead and overwrite it.

*

* @see @see org.java_websocket.WebSocketListener#onWebsocketError(WebSocket, Exception)

*/

@Override

public void onWebsocketError( WebSocket conn, Exception ex ) {

}

}