|
6 | 6 | import io.jooby.SneakyThrows; |
7 | 7 | import io.jooby.WebSocket; |
8 | 8 | import io.jooby.WebSocketCloseStatus; |
9 | | -import io.jooby.WebSocketListener; |
| 9 | +import io.jooby.WebSocketConfigurer; |
10 | 10 | import io.jooby.WebSocketMessage; |
11 | 11 | import io.netty.buffer.ByteBuf; |
12 | 12 | import io.netty.buffer.Unpooled; |
|
23 | 23 | import java.util.concurrent.ConcurrentMap; |
24 | 24 | import java.util.concurrent.CopyOnWriteArrayList; |
25 | 25 |
|
26 | | -public class NettyWebSocket implements WebSocketListener, WebSocket { |
| 26 | +public class NettyWebSocket implements WebSocketConfigurer, WebSocket { |
27 | 27 | /** All connected websocket. */ |
28 | 28 | private static final ConcurrentMap<String, List<WebSocket>> all = new ConcurrentHashMap<>(); |
29 | 29 |
|
@@ -92,22 +92,22 @@ public boolean isOpen() { |
92 | 92 | return netty.ctx.channel().isOpen(); |
93 | 93 | } |
94 | 94 |
|
95 | | - @Override public WebSocketListener onConnect(WebSocket.OnConnect callback) { |
| 95 | + @Override public WebSocketConfigurer onConnect(WebSocket.OnConnect callback) { |
96 | 96 | connectCallback = callback; |
97 | 97 | return this; |
98 | 98 | } |
99 | 99 |
|
100 | | - @Override public WebSocketListener onMessage(WebSocket.OnMessage callback) { |
| 100 | + @Override public WebSocketConfigurer onMessage(WebSocket.OnMessage callback) { |
101 | 101 | messageCallback = callback; |
102 | 102 | return this; |
103 | 103 | } |
104 | 104 |
|
105 | | - @Override public WebSocketListener onClose(WebSocket.OnClose callback) { |
| 105 | + @Override public WebSocketConfigurer onClose(WebSocket.OnClose callback) { |
106 | 106 | onCloseCallback = callback; |
107 | 107 | return this; |
108 | 108 | } |
109 | 109 |
|
110 | | - @Override public WebSocketListener onError(OnError callback) { |
| 110 | + @Override public WebSocketConfigurer onError(OnError callback) { |
111 | 111 | onErrorCallback = callback; |
112 | 112 | return this; |
113 | 113 | } |
|
0 commit comments