FilesExpand file tree

 master

/

WebSocketAdapter.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

161 lines (142 loc) · 5.57 KB

 master

/

WebSocketAdapter.java

Copy path

Top

File metadata and controls

• Code
• Blame

161 lines (142 loc) · 5.57 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

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

package org.java_websocket;

import java.nio.ByteBuffer;

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;

import java.util.Date;

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 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 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 org.java_websocket.WebSocketListener#onWebsocketMessage(WebSocket, byte[])

*/

@Override

public void onWebsocketMessage( WebSocket conn, ByteBuffer 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 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 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 org.java_websocket.WebSocketListener#onWebsocketError(WebSocket, Exception)

*/

@Override

public void onWebsocketError( WebSocket conn, Exception ex ) {

}

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

*

* @see org.java_websocket.WebSocketListener#connectTiming(Date startTime, Date endTime)

*/

@Override

public void connectTiming( Date startTime, Date endTime ) {

}

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

*

* @see org.java_websocket.WebSocketListener#messageSendTiming(Date startTime, Date endTime, MessageType type, int bytesAmount)

*/

@Override

public void messageSendTiming( Date startTime, Date endTime, MessageType type, int bytesAmount ) {

}

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

*

* @see org.java_websocket.WebSocketListener#messageReceiveTiming(Date startTime, Date endTime, MessageType type, int bytesAmount)

*/

@Override

public void messageReceiveTiming( Date startTime, Date endTime, MessageType type, int bytesAmount ) {

}

}