Upgrade to Jetty 12.1 onWebSocketClose signature

jhoeller · jhoeller · commit 3fb3b3d1b9fc · 2025-09-08T18:55:52.000+02:00
See spring-projectsgh-35345
diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/JettyWebSocketHandlerAdapter.java b/spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/JettyWebSocketHandlerAdapter.java
@@ -98,9 +98,10 @@ public void onWebSocketPong(ByteBuffer payload) {
 	}
 
 	@Override
-	public void onWebSocketClose(int statusCode, String reason) {
+	public void onWebSocketClose(int statusCode, String reason, Callback callback) {
 		Assert.state(this.delegateSession != null, "No delegate session available");
 		this.delegateSession.handleClose(CloseStatus.create(statusCode, reason));
+		callback.succeed();
 	}
 
 	@Override

Original file line number	Diff line number	Diff line change
`@@ -98,9 +98,10 @@ public void onWebSocketPong(ByteBuffer payload) {`
`98`	`98`	`}`
`99`	`99`
`100`	`100`	`@Override`
`101`		`- public void onWebSocketClose(int statusCode, String reason) {`
	`101`	`+ public void onWebSocketClose(int statusCode, String reason, Callback callback) {`
`102`	`102`	`Assert.state(this.delegateSession != null, "No delegate session available");`
`103`	`103`	`this.delegateSession.handleClose(CloseStatus.create(statusCode, reason));`
	`104`	`+ callback.succeed();`
`104`	`105`	`}`
`105`	`106`
`106`	`107`	`@Override`