SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Bumping versions

Browse Source
This commit is contained in:
buildmaster
2023-01-13 02:11:10 +00:00
parent 2b19fb0b97
commit 52dbfeaa5a
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java
View File

@@ -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);