From 52dbfeaa5a2d706fd46274a12d37e32cfd3d5860 Mon Sep 17 00:00:00 2001
From: buildmaster <builds@springframework.org>
Date: Fri, 13 Jan 2023 02:11:10 +0000
Subject: [PATCH] Bumping versions

---
 .../gateway/filter/WebsocketRoutingFilter.java   | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java b/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java
index 8a3d1465..50e27773 100644
--- a/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java
+++ b/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java
@@ -209,18 +209,20 @@ public class WebsocketRoutingFilter implements GlobalFilter, Ordered {
 							.flatMap(proxySession::close);
 					// Use retain() for Reactor Netty
 					Mono<Void> proxySessionSend = proxySession
-							.send(session.receive().doOnNext(WebSocketMessage::retain)
-							.doOnNext(webSocketMessage -> {
+							.send(session.receive().doOnNext(WebSocketMessage::retain).doOnNext(webSocketMessage -> {
 								if (log.isTraceEnabled()) {
-									log.trace("proxySession(send from client): " + proxySession.getId() + ", corresponding session:" + session.getId() + ", packet: " + webSocketMessage.getPayloadAsText());
+									log.trace("proxySession(send from client): " + proxySession.getId()
+											+ ", corresponding session:" + session.getId() + ", packet: "
+											+ webSocketMessage.getPayloadAsText());
 								}
 							}));
 					// .log("proxySessionSend", Level.FINE);
-					Mono<Void> serverSessionSend = session
-							.send(proxySession.receive().doOnNext(WebSocketMessage::retain)
-							.doOnNext(webSocketMessage -> {
+					Mono<Void> serverSessionSend = session.send(
+							proxySession.receive().doOnNext(WebSocketMessage::retain).doOnNext(webSocketMessage -> {
 								if (log.isTraceEnabled()) {
-									log.trace("session(send from backend): " + session.getId() + ", corresponding proxySession:" + proxySession.getId() + " packet: " + webSocketMessage.getPayloadAsText());
+									log.trace("session(send from backend): " + session.getId()
+											+ ", corresponding proxySession:" + proxySession.getId() + " packet: "
+											+ webSocketMessage.getPayloadAsText());
 								}
 							}));
 					// .log("sessionSend", Level.FINE);