Skip to content

Commit dd63e32

Browse files
authored
Add ws-aggregator and bump version (#6)
1 parent 9f3c0b7 commit dd63e32

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

‎gradle.properties‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
# Only update version on publishing to Maven Central
2-
version=1.7.0
2+
version=1.7.1

‎transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/AbstractNetherNetXboxSignaling.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
2222
import io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory;
2323
import io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler;
24+
import io.netty.handler.codec.http.websocketx.WebSocketFrameAggregator;
2425
import io.netty.handler.codec.http.websocketx.WebSocketVersion;
2526
import io.netty.handler.ssl.SslContext;
2627
import io.netty.handler.ssl.SslContextBuilder;
@@ -114,6 +115,7 @@ protected void initChannel(SocketChannel ch) {
114115
p.addLast(sslCtx.newHandler(ch.alloc(), uri.getHost(), 443));
115116
p.addLast(new HttpClientCodec(), new HttpObjectAggregator(8192));
116117
p.addLast("ws-handshake", new WebSocketClientProtocolHandler(handshaker));
118+
p.addLast("ws-aggregator", new WebSocketFrameAggregator(16 * 1024)); // Allow 16KB aggregations
117119
p.addLast("handler", AbstractNetherNetXboxSignaling.this);
118120
}
119121
});

0 commit comments

Comments
 (0)