From 9fa061431c0b16f933071997f0b57705966fbc25 Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Tue, 26 Apr 2016 17:22:26 -0400 Subject: [PATCH] XML config properly initialize WS message broker stats Issue: SPR-14190 --- .../socket/config/MessageBrokerBeanDefinitionParser.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/spring-websocket/src/main/java/org/springframework/web/socket/config/MessageBrokerBeanDefinitionParser.java b/spring-websocket/src/main/java/org/springframework/web/socket/config/MessageBrokerBeanDefinitionParser.java index 6e31e25dc8..12778c9d80 100644 --- a/spring-websocket/src/main/java/org/springframework/web/socket/config/MessageBrokerBeanDefinitionParser.java +++ b/spring-websocket/src/main/java/org/springframework/web/socket/config/MessageBrokerBeanDefinitionParser.java @@ -590,10 +590,9 @@ class MessageBrokerBeanDefinitionParser implements BeanDefinitionParser { if (context.getRegistry().containsBeanDefinition(name)) { beanDef.getPropertyValues().add("outboundChannelExecutor", context.getRegistry().getBeanDefinition(name)); } - name = SCHEDULER_BEAN_NAME; - if (context.getRegistry().containsBeanDefinition(name)) { - beanDef.getPropertyValues().add("sockJsTaskScheduler", context.getRegistry().getBeanDefinition(name)); - } + Object scheduler = WebSocketNamespaceUtils.registerScheduler(SCHEDULER_BEAN_NAME, context, source); + beanDef.getPropertyValues().add("sockJsTaskScheduler", scheduler); + registerBeanDefByName("webSocketMessageBrokerStats", beanDef, context, source); }