Polishing
This commit is contained in:
@@ -59,8 +59,7 @@ public class WebMvcStompEndpointRegistry implements StompEndpointRegistry {
|
||||
|
||||
private final StompSubProtocolHandler stompHandler;
|
||||
|
||||
private final List<WebMvcStompWebSocketEndpointRegistration> registrations =
|
||||
new ArrayList<>();
|
||||
private final List<WebMvcStompWebSocketEndpointRegistration> registrations = new ArrayList<>();
|
||||
|
||||
|
||||
public WebMvcStompEndpointRegistry(WebSocketHandler webSocketHandler,
|
||||
|
||||
@@ -96,7 +96,7 @@ public class WebSocketConfigurationSupport {
|
||||
this.scheduler = new NoOpScheduler();
|
||||
}
|
||||
}
|
||||
return scheduler;
|
||||
return this.scheduler;
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -56,8 +56,8 @@ public abstract class WebSocketMessageBrokerConfigurationSupport extends Abstrac
|
||||
|
||||
@Override
|
||||
protected SimpAnnotationMethodMessageHandler createAnnotationMethodMessageHandler() {
|
||||
return new WebSocketAnnotationMethodMessageHandler(clientInboundChannel(),
|
||||
clientOutboundChannel(), brokerMessagingTemplate());
|
||||
return new WebSocketAnnotationMethodMessageHandler(
|
||||
clientInboundChannel(), clientOutboundChannel(), brokerMessagingTemplate());
|
||||
}
|
||||
|
||||
@Override
|
||||
@@ -68,8 +68,8 @@ public abstract class WebSocketMessageBrokerConfigurationSupport extends Abstrac
|
||||
@Bean
|
||||
public HandlerMapping stompWebSocketHandlerMapping() {
|
||||
WebSocketHandler handler = decorateWebSocketHandler(subProtocolWebSocketHandler());
|
||||
WebMvcStompEndpointRegistry registry = new WebMvcStompEndpointRegistry(handler,
|
||||
getTransportRegistration(), messageBrokerTaskScheduler());
|
||||
WebMvcStompEndpointRegistry registry = new WebMvcStompEndpointRegistry(
|
||||
handler, getTransportRegistration(), messageBrokerTaskScheduler());
|
||||
ApplicationContext applicationContext = getApplicationContext();
|
||||
if (applicationContext != null) {
|
||||
registry.setApplicationContext(applicationContext);
|
||||
|
||||
Reference in New Issue
Block a user