zjtech.websocket.termination.config

Class WsConnectionAutoConfigure

java.lang.Object

zjtech.websocket.termination.config.WsConnectionAutoConfigure

@ConditionalOnProperty(name="websocket.termination.enabled",
                       matchIfMissing=true)
 @EnableConfigurationProperties(value=WsConnectionConfigProps.class)
 @AutoConfigureOrder
 @ConditionalOnClass(value=org.springframework.web.reactive.DispatcherHandler.class)
public class WsConnectionAutoConfigure
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
WsConnectionAutoConfigure()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.EmitterProcessor<SessionHandler>	clientConnectedEventBus(IClientConnectionListener clientConnectionListener) Init a event bus for handling client connection.
IClientConnectionListener	clientConnectionListener(ISessionHolder sessionHolder)
reactor.core.publisher.EmitterProcessor<SessionHandler>	clientDisConnectedEventBus(IClientConnectionListener clientConnectionListener) Init a event bus for handling client disconnection.
CommandMappingHandler	commandMappingHandler(WsConnectionConfigProps connectionConfigProps)
org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter	handlerAdapter()
MessageHandler	messageHandler(WsUtils wsUtils, CommandMappingHandler commandMappingHandler)
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()
PingPongHandler	pingPongHandler(WsConnectionConfigProps configProps)
IRequestParser	requestParser(WsUtils wsUtils, CommandMappingHandler commandMappingHandler)
SessionHandler	sessionHandler(WsUtils wsUtils, WsConnectionConfigProps configProps, reactor.core.publisher.EmitterProcessor<SessionHandler> clientConnectedEventBus, reactor.core.publisher.EmitterProcessor<SessionHandler> clientDisconnectedEventBus)
ISessionHolder	sessionHolder() Register a session holder bean for maintaining the websocket session in memory.
org.springframework.web.reactive.socket.client.WebSocketClient	webSocketClient()
WebSocketConnectionEndPoint	webSocketConnectionEndPoint(CommandMappingHandler mappingHandler, ISessionHolder sessionHolder)
org.springframework.web.reactive.socket.WebSocketHandler	webSocketHandler(WsUtils wsUtils)
org.springframework.web.reactive.HandlerMapping	webSocketHandlerMapping(WsConnectionConfigProps connectionConfigProps, WsUtils utils) Initialize a handler mapping for websocket.
WebSocketMessageEndPoint	webSocketMessageEndPoint(CommandMappingHandler mappingHandler, ISessionHolder sessionHolder)
WsUtils	wsUtils(org.springframework.context.ApplicationContext ctx)

Methods inherited from class java.lang.Object

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

Constructor Detail

WsConnectionAutoConfigure

public WsConnectionAutoConfigure()

Method Detail

webSocketClient

@Bean
 @ConditionalOnMissingBean
public org.springframework.web.reactive.socket.client.WebSocketClient webSocketClient()

objectMapper

@Bean
 @ConditionalOnMissingBean
public com.fasterxml.jackson.databind.ObjectMapper objectMapper()

wsUtils

@Bean
 @ConditionalOnMissingBean
public WsUtils wsUtils(org.springframework.context.ApplicationContext ctx)

commandMappingHandler

@Bean
 @ConditionalOnMissingBean
public CommandMappingHandler commandMappingHandler(WsConnectionConfigProps connectionConfigProps)

sessionHolder

@Bean
 @ConditionalOnMissingBean
public ISessionHolder sessionHolder()

Register a session holder bean for maintaining the websocket session in memory.

Returns:

ISessionHolder

handlerAdapter

@Bean
 @ConditionalOnMissingBean
public org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter handlerAdapter()

webSocketHandler

@Bean
 @ConditionalOnMissingBean
public org.springframework.web.reactive.socket.WebSocketHandler webSocketHandler(WsUtils wsUtils)

webSocketHandlerMapping

@Bean
public org.springframework.web.reactive.HandlerMapping webSocketHandlerMapping(WsConnectionConfigProps connectionConfigProps,
                                                                                     WsUtils utils)

Initialize a handler mapping for websocket.

Parameters:

connectionConfigProps - WsConnectionConfigProps

Returns:

HandlerMapping

clientConnectionListener

@Bean
public IClientConnectionListener clientConnectionListener(ISessionHolder sessionHolder)

clientConnectedEventBus

@Bean(name="clientConnectedEventBus")
public reactor.core.publisher.EmitterProcessor<SessionHandler> clientConnectedEventBus(IClientConnectionListener clientConnectionListener)

Init a event bus for handling client connection.

Parameters:

clientConnectionListener - IClientConnectionListener

Returns:

EmitterProcessor

clientDisConnectedEventBus

@Bean(name="clientDisConnectedEventBus")
public reactor.core.publisher.EmitterProcessor<SessionHandler> clientDisConnectedEventBus(IClientConnectionListener clientConnectionListener)

Init a event bus for handling client disconnection.

Parameters:

clientConnectionListener - IClientConnectionListener

Returns:

EmitterProcessor

messageHandler

@Bean
 @Scope(value="prototype")
public MessageHandler messageHandler(WsUtils wsUtils,
                                                                      CommandMappingHandler commandMappingHandler)

sessionHandler

@Bean
 @Scope(value="prototype")
public SessionHandler sessionHandler(WsUtils wsUtils,
                                                                      WsConnectionConfigProps configProps,
                                                                      @Qualifier(value="clientConnectedEventBus")
                                                                      reactor.core.publisher.EmitterProcessor<SessionHandler> clientConnectedEventBus,
                                                                      @Qualifier(value="clientDisConnectedEventBus")
                                                                      reactor.core.publisher.EmitterProcessor<SessionHandler> clientDisconnectedEventBus)

pingPongHandler

@Bean
 @Scope(value="prototype")
 @ConditionalOnProperty(name="websocket.termination.ping.enabled",
                       matchIfMissing=true)
public PingPongHandler pingPongHandler(WsConnectionConfigProps configProps)

requestParser

@Bean
public IRequestParser requestParser(WsUtils wsUtils,
                                          CommandMappingHandler commandMappingHandler)

webSocketConnectionEndPoint

@Bean
 @ConditionalOnEnabledEndpoint
public WebSocketConnectionEndPoint webSocketConnectionEndPoint(CommandMappingHandler mappingHandler,
                                                                                                    ISessionHolder sessionHolder)

webSocketMessageEndPoint

@Bean
 @ConditionalOnEnabledEndpoint
public WebSocketMessageEndPoint webSocketMessageEndPoint(CommandMappingHandler mappingHandler,
                                                                                              ISessionHolder sessionHolder)