Fixed refactoring
@@ -79,8 +79,8 @@ public class MqttWebSocketInitializer {
.addLast(HTTP_CODEC_NAME, new HttpClientCodec())
.addLast(HTTP_AGGREGATOR_NAME, new HttpObjectAggregator(65_535))
.addLast(MqttWebsocketHandshakeHandler.NAME,
- new MqttWebsocketHandshakeHandler(handshaker, onSuccess, onError,
- webSocketConfig.getHandshakeTimeoutMs()))
+ new MqttWebsocketHandshakeHandler(handshaker, webSocketConfig.getHandshakeTimeoutMs(),
+ onSuccess, onError))
.addLast(MqttWebSocketCodec.NAME, mqttWebSocketCodec);
}
}
