com.github.mthizo247.cloud.netflix.zuul.web.socket

Class ZuulWebSocketConfiguration

java.lang.Object

org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer

com.github.mthizo247.cloud.netflix.zuul.web.socket.ZuulWebSocketConfiguration

All Implemented Interfaces:

EventListener, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>, org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer

@Configuration
 @ConditionalOnWebApplication
 @ConditionalOnClass(value=org.springframework.web.socket.WebSocketHandler.class)
 @EnableConfigurationProperties(value=ZuulWebSocketProperties.class)
public class ZuulWebSocketConfiguration
extends org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer
implements org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

Zuul reverse proxy web socket configuration

Author:

Ronald Mthombeni, Salman Noor

Constructor Summary

Constructors

Constructor and Description
ZuulWebSocketConfiguration()

Method Summary

Modifier and Type	Method and Description
WebSocketHttpHeadersCallback	basicAuthPrincipalHeadersCallback()
ProxyWebSocketErrorHandler	compositeErrorHandler(List<ProxyWebSocketErrorHandler> errorHandlers)
WebSocketHttpHeadersCallback	compositeHeadersCallback(List<WebSocketHttpHeadersCallback> headersCallbacks)
ProxyTargetResolver	compositeProxyTargetResolver(List<ProxyTargetResolver> resolvers)
void	configureMessageBroker(org.springframework.messaging.simp.config.MessageBrokerRegistry config)
void	configureWebSocketTransport(org.springframework.web.socket.config.annotation.WebSocketTransportRegistration registration)
ProxyTargetResolver	discoveryProxyTargetResolver(org.springframework.cloud.netflix.zuul.filters.ZuulProperties zuulProperties, org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient)
void	init()
ProxyTargetResolver	loadBalancedProxyTargetResolver(org.springframework.cloud.netflix.zuul.filters.ZuulProperties zuulProperties, org.springframework.cloud.client.loadbalancer.LoadBalancerClient loadBalancerClient)
WebSocketHttpHeadersCallback	loginCookieHeadersCallback()
WebSocketHttpHeadersCallback	oauth2BearerPrincipalHeadersCallback()
void	onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)
ProxyRedirectFilter	proxyRedirectFilter(org.springframework.cloud.netflix.zuul.filters.RouteLocator routeLocator)
ProxyWebSocketErrorHandler	reconnectErrorHandler()
void	registerStompEndpoints(org.springframework.web.socket.config.annotation.StompEndpointRegistry registry)
org.springframework.web.socket.messaging.WebSocketStompClient	stompClient(org.springframework.messaging.converter.MessageConverter messageConverter, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler)
org.springframework.scheduling.TaskScheduler	stompClientTaskScheduler()
ProxyTargetResolver	urlProxyTargetResolver(org.springframework.cloud.netflix.zuul.filters.ZuulProperties zuulProperties)

Methods inherited from class org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer

addArgumentResolvers, addReturnValueHandlers, configureClientInboundChannel, configureClientOutboundChannel, configureMessageConverters

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZuulWebSocketConfiguration

public ZuulWebSocketConfiguration()

Method Detail

registerStompEndpoints

public void registerStompEndpoints(org.springframework.web.socket.config.annotation.StompEndpointRegistry registry)

Specified by:

registerStompEndpoints in interface org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer

configureMessageBroker

public void configureMessageBroker(org.springframework.messaging.simp.config.MessageBrokerRegistry config)

Specified by:

configureMessageBroker in interface org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer

Overrides:

configureMessageBroker in class org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer

configureWebSocketTransport

public void configureWebSocketTransport(org.springframework.web.socket.config.annotation.WebSocketTransportRegistration registration)

Specified by:

configureWebSocketTransport in interface org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer

Overrides:

configureWebSocketTransport in class org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer

compositeHeadersCallback

@Bean
 @Primary
public WebSocketHttpHeadersCallback compositeHeadersCallback(List<WebSocketHttpHeadersCallback> headersCallbacks)

basicAuthPrincipalHeadersCallback

@Bean
 @ConditionalOnClass(name="org.springframework.security.core.Authentication")
public WebSocketHttpHeadersCallback basicAuthPrincipalHeadersCallback()

oauth2BearerPrincipalHeadersCallback

@Bean
 @ConditionalOnClass(name="org.springframework.security.core.OAuth2Authentication")
public WebSocketHttpHeadersCallback oauth2BearerPrincipalHeadersCallback()

loginCookieHeadersCallback

@Bean
public WebSocketHttpHeadersCallback loginCookieHeadersCallback()

urlProxyTargetResolver

@Bean
public ProxyTargetResolver urlProxyTargetResolver(org.springframework.cloud.netflix.zuul.filters.ZuulProperties zuulProperties)

discoveryProxyTargetResolver

@Bean
public ProxyTargetResolver discoveryProxyTargetResolver(org.springframework.cloud.netflix.zuul.filters.ZuulProperties zuulProperties,
                                                               org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient)

loadBalancedProxyTargetResolver

@Bean
public ProxyTargetResolver loadBalancedProxyTargetResolver(org.springframework.cloud.netflix.zuul.filters.ZuulProperties zuulProperties,
                                                                  org.springframework.cloud.client.loadbalancer.LoadBalancerClient loadBalancerClient)

compositeProxyTargetResolver

@Bean
 @Primary
public ProxyTargetResolver compositeProxyTargetResolver(List<ProxyTargetResolver> resolvers)

stompClient

@Bean
 @ConditionalOnMissingBean(value=org.springframework.web.socket.messaging.WebSocketStompClient.class)
public org.springframework.web.socket.messaging.WebSocketStompClient stompClient(org.springframework.messaging.converter.MessageConverter messageConverter,
                                                                                                                                                                                               org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler)

stompClientTaskScheduler

@Bean
 @ConditionalOnMissingBean(value=org.springframework.scheduling.TaskScheduler.class)
public org.springframework.scheduling.TaskScheduler stompClientTaskScheduler()

reconnectErrorHandler

@Bean
public ProxyWebSocketErrorHandler reconnectErrorHandler()

compositeErrorHandler

@Bean
 @Primary
public ProxyWebSocketErrorHandler compositeErrorHandler(List<ProxyWebSocketErrorHandler> errorHandlers)

proxyRedirectFilter

@Bean
public ProxyRedirectFilter proxyRedirectFilter(org.springframework.cloud.netflix.zuul.filters.RouteLocator routeLocator)

init

@PostConstruct
public void init()

onApplicationEvent

public void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>