@ -113,7 +113,8 @@ public class ReactorNettyWebSocketClient implements WebSocketClient {
@@ -113,7 +113,8 @@ public class ReactorNettyWebSocketClient implements WebSocketClient {
String protocol = responseHeaders . getFirst ( "Sec-WebSocket-Protocol" ) ;
HandshakeInfo info = new HandshakeInfo ( url , responseHeaders , Mono . empty ( ) , protocol ) ;
NettyDataBufferFactory factory = new NettyDataBufferFactory ( outbound . alloc ( ) ) ;
WebSocketSession session = new ReactorNettyWebSocketSession ( inbound , outbound , info , factory ) ;
WebSocketSession session = new ReactorNettyWebSocketSession (
inbound , outbound , info , factory , getMaxFramePayloadLength ( ) ) ;
if ( logger . isDebugEnabled ( ) ) {
logger . debug ( "Started session '" + session . getId ( ) + "' for " + url ) ;
}