diff --git a/server/src/main/java/lingo/server/WebSocketConfig.java b/server/src/main/java/lingo/server/WebSocketConfig.java index b048fe3..d710e8a 100644 --- a/server/src/main/java/lingo/server/WebSocketConfig.java +++ b/server/src/main/java/lingo/server/WebSocketConfig.java @@ -1,6 +1,7 @@ package lingo.server; import org.springframework.context.annotation.Configuration; +import org.springframework.messaging.simp.config.ChannelRegistration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer; import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker; @@ -10,6 +11,18 @@ import org.springframework.web.socket.config.annotation.StompEndpointRegistry; @EnableWebSocketMessageBroker public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { + @Override + public void configureClientInboundChannel(ChannelRegistration registration) { + // Single thread unless/until more threads are needed + registration.taskExecutor().corePoolSize(1); + } + + @Override + public void configureClientOutboundChannel(ChannelRegistration registration) { + // Single thread unless/until more threads are needed + registration.taskExecutor().corePoolSize(1); + } + @Override public void configureMessageBroker(MessageBrokerRegistry config) { config.enableSimpleBroker("/topic");