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") }