zjtech.websocket.termination.core

Class SessionHandler

java.lang.Object

zjtech.websocket.termination.core.SessionHandler

public class SessionHandler
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SessionHandler(WsUtils wsUtils, WsConnectionConfigProps configProps, reactor.core.publisher.EmitterProcessor<SessionHandler> clientConnectedEventBus, reactor.core.publisher.EmitterProcessor<SessionHandler> clientDisconnectedEventBus) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close() Blocking close for a websocket session.
java.lang.String	getClientInfo()
org.springframework.web.reactive.socket.WebSocketSession	getSession()
java.lang.String	getSessionId()
reactor.core.publisher.Mono<java.lang.Void>	handle(org.springframework.web.reactive.socket.WebSocketSession webSocketSession) Handle the session.
boolean	isConnected()
void	notifyConnect()
void	notifyDisconnect()
reactor.core.publisher.DirectProcessor<org.springframework.web.reactive.socket.WebSocketMessage>	pong()
reactor.core.publisher.DirectProcessor<java.lang.String>	receive()
void	send(org.springframework.web.reactive.socket.WebSocketMessage msg) Send the raw websocket message.
void	send(org.springframework.web.reactive.socket.WebSocketMessage msg, org.springframework.web.reactive.socket.WebSocketSession webSocketSession) Send the raw websocket message.
void	sendJsonString(java.lang.Object messageObj) Send a object in json format.
void	sendJsonString(java.lang.Object messageObj, org.springframework.web.reactive.socket.WebSocketSession customSession) Send a object in json format.
void	sendText(java.lang.String message) Send a string to client.
void	sendText(java.lang.String message, org.springframework.web.reactive.socket.WebSocketSession webSocketSession) Send a string to client.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionHandler

public SessionHandler(WsUtils wsUtils,
                      WsConnectionConfigProps configProps,
                      reactor.core.publisher.EmitterProcessor<SessionHandler> clientConnectedEventBus,
                      reactor.core.publisher.EmitterProcessor<SessionHandler> clientDisconnectedEventBus)

Constructor.

Parameters:

wsUtils - WsUtils

configProps - WsConnectionConfigProps

clientConnectedEventBus - EmitterProcessor

clientDisconnectedEventBus - EmitterProcessor

Method Detail

handle

public reactor.core.publisher.Mono<java.lang.Void> handle(org.springframework.web.reactive.socket.WebSocketSession webSocketSession)

Handle the session.

Parameters:

webSocketSession - WebSocketSession

Returns:

Mono

sendJsonString

public void sendJsonString(java.lang.Object messageObj)

Send a object in json format.

Parameters:

messageObj - Object

sendJsonString

public void sendJsonString(java.lang.Object messageObj,
                           org.springframework.web.reactive.socket.WebSocketSession customSession)

Send a object in json format.

Parameters:

messageObj - Object

sendText

public void sendText(java.lang.String message)

Send a string to client.

Parameters:

message - string

sendText

public void sendText(java.lang.String message,
                     org.springframework.web.reactive.socket.WebSocketSession webSocketSession)

Send a string to client.

Parameters:

message - string

send

public void send(org.springframework.web.reactive.socket.WebSocketMessage msg)

Send the raw websocket message.

Parameters:

msg - WebSocketMessage

send

public void send(org.springframework.web.reactive.socket.WebSocketMessage msg,
                 org.springframework.web.reactive.socket.WebSocketSession webSocketSession)

Send the raw websocket message.

Parameters:

msg - WebSocketMessage

pong

public reactor.core.publisher.DirectProcessor<org.springframework.web.reactive.socket.WebSocketMessage> pong()

close

public void close()

Blocking close for a websocket session.

getClientInfo

public java.lang.String getClientInfo()

receive

public reactor.core.publisher.DirectProcessor<java.lang.String> receive()

notifyConnect

public void notifyConnect()

notifyDisconnect

public void notifyDisconnect()

getSessionId

public java.lang.String getSessionId()

isConnected

public boolean isConnected()

getSession

public org.springframework.web.reactive.socket.WebSocketSession getSession()