-
Notifications
You must be signed in to change notification settings - Fork 0
/
MuleAgentWebSocket.groovy
79 lines (60 loc) · 1.86 KB
/
MuleAgentWebSocket.groovy
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
@Grab(group='org.java-websocket', module='Java-WebSocket', version='1.3.0')
import org.java_websocket.WebSocket
import org.java_websocket.WebSocketImpl
import org.java_websocket.handshake.ClientHandshake
import org.java_websocket.server.WebSocketServer
import java.io.IOException
import java.net.InetSocketAddress
import java.util.Collection
/**
* Created by espinraf on 18/05/15.
*/
class MuleAgentWebSocket extends WebSocketServer {
MuleAgentWebSocket(int port) {
super( new InetSocketAddress( port ) );
}
MuleAgentWebSocket(InetSocketAddress address) {
super( address );
}
@Override
public void onOpen( WebSocket conn, ClientHandshake handshake ) {
println 'Open'
}
@Override
public void onClose( WebSocket conn, int code, String reason, boolean remote ) {
println 'Close'
}
@Override
public void onMessage( WebSocket conn, String message ) {
//this.sendToAll( message );
println conn + ": " + message
}
@Override
public void onError( WebSocket conn, Exception ex ) {
println 'Error'
}
public void startDebug() throws InterruptedException , IOException {
WebSocketImpl.DEBUG = true;
this.start();
println 'Server started on port: 9090'
}
/**
* Sends <var>text</var> to all currently connected WebSocket clients.
*
* @param text
* The String to send across the network.
* @throws InterruptedException
* When socket related I/O errors occur.
*/
public void sendToAll( String text ) {
Collection<WebSocket> con = connections();
synchronized ( con ) {
for( WebSocket c : con ) {
c.send( text );
}
}
}
public void updateWebPage(WebSocket con, String text ) {
con.send( text );
}
}