You've already forked Arcturus-Morningstar-Extended
mirror of
https://github.com/duckietm/Arcturus-Morningstar-Extended.git
synced 2026-06-20 15:36:17 +00:00
🆙 Small fix for the websocket, some CF users have problems with the max frame size
This commit is contained in:
+2
@@ -18,6 +18,7 @@ import io.netty.channel.ChannelInitializer;
|
|||||||
import io.netty.channel.socket.SocketChannel;
|
import io.netty.channel.socket.SocketChannel;
|
||||||
import io.netty.handler.codec.http.HttpObjectAggregator;
|
import io.netty.handler.codec.http.HttpObjectAggregator;
|
||||||
import io.netty.handler.codec.http.HttpServerCodec;
|
import io.netty.handler.codec.http.HttpServerCodec;
|
||||||
|
import io.netty.handler.codec.http.websocketx.WebSocketFrameAggregator;
|
||||||
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolConfig;
|
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolConfig;
|
||||||
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
|
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
|
||||||
import io.netty.handler.logging.LoggingHandler;
|
import io.netty.handler.logging.LoggingHandler;
|
||||||
@@ -60,6 +61,7 @@ public class WebSocketChannelInitializer extends ChannelInitializer<SocketChanne
|
|||||||
ch.pipeline().addLast("authHttpHandler", new AuthHttpHandler());
|
ch.pipeline().addLast("authHttpHandler", new AuthHttpHandler());
|
||||||
ch.pipeline().addLast("badgeHttpHandler", new BadgeHttpHandler());
|
ch.pipeline().addLast("badgeHttpHandler", new BadgeHttpHandler());
|
||||||
ch.pipeline().addLast("wsProtocolHandler", new WebSocketServerProtocolHandler(this.wsConfig));
|
ch.pipeline().addLast("wsProtocolHandler", new WebSocketServerProtocolHandler(this.wsConfig));
|
||||||
|
ch.pipeline().addLast("wsFrameAggregator", new WebSocketFrameAggregator(MAX_FRAME_SIZE));
|
||||||
ch.pipeline().addLast("wsCodec", new WebSocketCodec());
|
ch.pipeline().addLast("wsCodec", new WebSocketCodec());
|
||||||
|
|
||||||
if (Emulator.getConfig().getBoolean("crypto.ws.enabled", false)) {
|
if (Emulator.getConfig().getBoolean("crypto.ws.enabled", false)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user