From 8f0f5faf4d541df10db9b38e670bed83a1990b98 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 3c8ebc28ce..9caa5a8f2e 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 @@ -620,10 +620,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); }