@@ -152,7 +152,6 @@ private QwpWebSocketSender(
152152 String host ,
153153 int port ,
154154 boolean tlsEnabled ,
155- int bufferSize ,
156155 int autoFlushRows ,
157156 int autoFlushBytes ,
158157 long autoFlushIntervalNanos ,
@@ -164,7 +163,7 @@ private QwpWebSocketSender(
164163 this .host = host ;
165164 this .port = port ;
166165 this .tlsEnabled = tlsEnabled ;
167- this .encoder = new QwpWebSocketEncoder (bufferSize );
166+ this .encoder = new QwpWebSocketEncoder (DEFAULT_BUFFER_SIZE );
168167 this .tableBuffers = new CharSequenceObjHashMap <>();
169168 this .currentTableBuffer = null ;
170169 this .currentTableName = null ;
@@ -276,7 +275,7 @@ public static QwpWebSocketSender connect(
276275 int maxSchemasPerConnection
277276 ) {
278277 QwpWebSocketSender sender = new QwpWebSocketSender (
279- host , port , tlsEnabled , DEFAULT_BUFFER_SIZE ,
278+ host , port , tlsEnabled ,
280279 autoFlushRows , autoFlushBytes , autoFlushIntervalNanos ,
281280 inFlightWindowSize , authorizationHeader , maxSchemasPerConnection
282281 );
@@ -302,7 +301,7 @@ public static QwpWebSocketSender connect(
302301 */
303302 public static QwpWebSocketSender createForTesting (String host , int port , int inFlightWindowSize ) {
304303 return new QwpWebSocketSender (
305- host , port , false , DEFAULT_BUFFER_SIZE ,
304+ host , port , false ,
306305 DEFAULT_AUTO_FLUSH_ROWS , DEFAULT_AUTO_FLUSH_BYTES , DEFAULT_AUTO_FLUSH_INTERVAL_NANOS ,
307306 inFlightWindowSize , null , DEFAULT_MAX_SCHEMAS_PER_CONNECTION
308307 );
@@ -348,7 +347,7 @@ public static QwpWebSocketSender createForTesting(
348347 int maxSchemasPerConnection
349348 ) {
350349 return new QwpWebSocketSender (
351- host , port , false , DEFAULT_BUFFER_SIZE ,
350+ host , port , false ,
352351 autoFlushRows , autoFlushBytes , autoFlushIntervalNanos ,
353352 inFlightWindowSize , null , maxSchemasPerConnection
354353 );
0 commit comments