com.github.antennaesdk.messageserver.ws

Class ClientTextWebSocketHandler

java.lang.Object

org.springframework.web.socket.handler.AbstractWebSocketHandler

org.springframework.web.socket.handler.TextWebSocketHandler

com.github.antennaesdk.messageserver.ws.ClientTextWebSocketHandler

All Implemented Interfaces:

IClientHandler, org.springframework.web.socket.WebSocketHandler

public class ClientTextWebSocketHandler
extends org.springframework.web.socket.handler.TextWebSocketHandler
implements IClientHandler

ClientTextWebSocketHandler receives the incoming web-socket messages. reads the json, identifies the topic and then sends it to the TopicProcessor

Constructor Summary

Constructors

Constructor and Description
ClientTextWebSocketHandler()

Method Summary

Modifier and Type	Method and Description
void	afterConnectionClosed(org.springframework.web.socket.WebSocketSession session, org.springframework.web.socket.CloseStatus status)
void	afterConnectionEstablished(org.springframework.web.socket.WebSocketSession session)
void	handleTextMessage(org.springframework.web.socket.WebSocketSession session, org.springframework.web.socket.TextMessage incomingMessage) All messages from real-clients are received by this method.
void	handleTransportError(org.springframework.web.socket.WebSocketSession session, Throwable exception)
void	init()
void	routeMessage(org.springframework.web.socket.WebSocketSession session, String textMessage) routeMessage routes the message based on the payload to appropriate Processors.
void	sendToClient(ClientMessageWrapper clientMessageWrapper) sendToClient sends the message to clients ( real-world clients ).
void	sendToClient(org.springframework.web.socket.WebSocketSession session, ClientMessage clientMessage)
void	shutdown()

Methods inherited from class org.springframework.web.socket.handler.TextWebSocketHandler

handleBinaryMessage

Methods inherited from class org.springframework.web.socket.handler.AbstractWebSocketHandler

handleMessage, handlePongMessage, supportsPartialMessages

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientTextWebSocketHandler

public ClientTextWebSocketHandler()

Method Detail

init

@PostConstruct
public void init()

shutdown

@PreDestroy
public void shutdown()

afterConnectionEstablished

public void afterConnectionEstablished(org.springframework.web.socket.WebSocketSession session)
                                throws Exception

Specified by:

afterConnectionEstablished in interface org.springframework.web.socket.WebSocketHandler

Overrides:

afterConnectionEstablished in class org.springframework.web.socket.handler.AbstractWebSocketHandler

Throws:

Exception

handleTransportError

public void handleTransportError(org.springframework.web.socket.WebSocketSession session,
                                 Throwable exception)
                          throws Exception

Specified by:

handleTransportError in interface org.springframework.web.socket.WebSocketHandler

Overrides:

handleTransportError in class org.springframework.web.socket.handler.AbstractWebSocketHandler

Throws:

Exception

afterConnectionClosed

public void afterConnectionClosed(org.springframework.web.socket.WebSocketSession session,
                                  org.springframework.web.socket.CloseStatus status)
                           throws Exception

Specified by:

afterConnectionClosed in interface org.springframework.web.socket.WebSocketHandler

Overrides:

afterConnectionClosed in class org.springframework.web.socket.handler.AbstractWebSocketHandler

Throws:

Exception

handleTextMessage

public void handleTextMessage(org.springframework.web.socket.WebSocketSession session,
                              org.springframework.web.socket.TextMessage incomingMessage)

All messages from real-clients are received by this method.

Overrides:

handleTextMessage in class org.springframework.web.socket.handler.AbstractWebSocketHandler

Parameters:

session -

incomingMessage -

routeMessage

public void routeMessage(org.springframework.web.socket.WebSocketSession session,
                         String textMessage)

routeMessage routes the message based on the payload to appropriate Processors.

Parameters:

session -

textMessage -

sendToClient

public void sendToClient(ClientMessageWrapper clientMessageWrapper)

sendToClient sends the message to clients ( real-world clients ). It first tries to send through an existing session (connection). If connection is not found, then sends the message through GCM/APNS.

Specified by:

sendToClient in interface IClientHandler

Parameters:

clientMessageWrapper - Message targetted for the client

sendToClient

public void sendToClient(org.springframework.web.socket.WebSocketSession session,
                         ClientMessage clientMessage)