org.apache.ambari.server.configuration.spring

Class AgentStompConfig

java.lang.Object

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

org.apache.ambari.server.configuration.spring.AgentStompConfig

All Implemented Interfaces:

org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer

@Configuration
 @EnableWebSocketMessageBroker
 @ComponentScan(basePackageClasses=HeartbeatController.class)
 @Import(value={RootStompConfig.class,GuiceBeansConfig.class})
public class AgentStompConfig
extends org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer

Constructor Summary

Constructors

Constructor and Description
AgentStompConfig(javax.servlet.ServletContext servletContext, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
void	configureClientInboundChannel(org.springframework.messaging.simp.config.ChannelRegistration registration)
void	configureClientOutboundChannel(org.springframework.messaging.simp.config.ChannelRegistration registration)
void	configureMessageBroker(org.springframework.messaging.simp.config.MessageBrokerRegistry registry)
void	configureWebSocketTransport(org.springframework.web.socket.config.annotation.WebSocketTransportRegistration registration)
org.springframework.web.socket.server.support.DefaultHandshakeHandler	getHandshakeHandler()
void	registerStompEndpoints(org.springframework.web.socket.config.annotation.StompEndpointRegistry registry)
STOMPUpdateListener	requestSTOMPListener(com.google.inject.Injector injector)

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

addArgumentResolvers, addReturnValueHandlers, configureMessageConverters

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentStompConfig

public AgentStompConfig(javax.servlet.ServletContext servletContext,
                        com.google.inject.Injector injector)

Method Detail

requestSTOMPListener

@Bean
public STOMPUpdateListener requestSTOMPListener(com.google.inject.Injector injector)

getHandshakeHandler

public org.springframework.web.socket.server.support.DefaultHandshakeHandler getHandshakeHandler()

registerStompEndpoints

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

configureClientInboundChannel

public void configureClientInboundChannel(org.springframework.messaging.simp.config.ChannelRegistration registration)

Specified by:

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

Overrides:

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

configureClientOutboundChannel

public void configureClientOutboundChannel(org.springframework.messaging.simp.config.ChannelRegistration registration)

Specified by:

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

Overrides:

configureClientOutboundChannel 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

configureMessageBroker

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

Specified by:

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

Overrides:

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