From 52aed88cc3c2fa1c089e390887ed76781837104a Mon Sep 17 00:00:00 2001 From: yaoxuwan Date: Mon, 2 Dec 2024 11:11:39 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20websocket=E4=BC=9A=E8=AF=9D=E8=87=AA?= =?UTF-8?q?=E5=8A=A8=E5=85=B3=E9=97=AD=20#2809?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tencent/bkrepo/websocket/config/WebsocketConfiguration.kt | 4 ---- 1 file changed, 4 deletions(-) diff --git a/src/backend/websocket/biz-websocket/src/main/kotlin/com/tencent/bkrepo/websocket/config/WebsocketConfiguration.kt b/src/backend/websocket/biz-websocket/src/main/kotlin/com/tencent/bkrepo/websocket/config/WebsocketConfiguration.kt index aced41f2e9..16717a366c 100644 --- a/src/backend/websocket/biz-websocket/src/main/kotlin/com/tencent/bkrepo/websocket/config/WebsocketConfiguration.kt +++ b/src/backend/websocket/biz-websocket/src/main/kotlin/com/tencent/bkrepo/websocket/config/WebsocketConfiguration.kt @@ -42,7 +42,6 @@ import org.springframework.context.annotation.Configuration import org.springframework.messaging.Message import org.springframework.messaging.simp.config.ChannelRegistration import org.springframework.messaging.simp.config.MessageBrokerRegistry -import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker import org.springframework.web.socket.config.annotation.StompEndpointRegistry import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer @@ -57,14 +56,11 @@ class WebsocketConfiguration( private val websocketService: WebsocketService, private val jwtAuthProperties: JwtAuthProperties, private val authenticationManager: AuthenticationManager, - private val taskScheduler: ThreadPoolTaskScheduler ) : WebSocketMessageBrokerConfigurer { override fun configureMessageBroker(config: MessageBrokerRegistry) { config.setCacheLimit(webSocketProperties.cacheLimit) config.enableSimpleBroker("/topic") - .setHeartbeatValue(longArrayOf(3000,3000)) - .setTaskScheduler(taskScheduler) config.setApplicationDestinationPrefixes("/app") }