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

Class ProxyWebSocketConnectionManager

java.lang.Object

org.springframework.web.socket.client.ConnectionManagerSupport

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

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.messaging.simp.stomp.StompFrameHandler, org.springframework.messaging.simp.stomp.StompSessionHandler

public class ProxyWebSocketConnectionManager
extends org.springframework.web.socket.client.ConnectionManagerSupport
implements org.springframework.messaging.simp.stomp.StompSessionHandler

A web socket connection manager bridge between client and backend server via zuul reverse proxy

Author:

Ronald Mthombeni, Salman Noor

Field Summary

Fields inherited from class org.springframework.web.socket.client.ConnectionManagerSupport

logger

Constructor Summary

Constructors

Constructor and Description
ProxyWebSocketConnectionManager(org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate, org.springframework.web.socket.messaging.WebSocketStompClient stompClient, org.springframework.web.socket.WebSocketSession userAgentSession, WebSocketHttpHeadersCallback httpHeadersCallback, String uri)

Method Summary

Modifier and Type	Method and Description
void	afterConnected(org.springframework.messaging.simp.stomp.StompSession session, org.springframework.messaging.simp.stomp.StompHeaders connectedHeaders)
protected void	closeConnection()
void	connect()
void	disconnect()
void	errorHandler(org.springframework.util.ErrorHandler errorHandler)
Type	getPayloadType(org.springframework.messaging.simp.stomp.StompHeaders headers)
void	handleException(org.springframework.messaging.simp.stomp.StompSession session, org.springframework.messaging.simp.stomp.StompCommand command, org.springframework.messaging.simp.stomp.StompHeaders headers, byte[] payload, Throwable ex)
void	handleFrame(org.springframework.messaging.simp.stomp.StompHeaders headers, Object payload)
void	handleTransportError(org.springframework.messaging.simp.stomp.StompSession session, Throwable ex)
protected boolean	isConnected()
boolean	isConnectedToUserAgent()
protected void	openConnection()
void	reconnect(long delay)
void	sendMessage(String destination, Object msg)
void	subscribe(String destination)
void	unsubscribe(String destination)

Methods inherited from class org.springframework.web.socket.client.ConnectionManagerSupport

getPhase, getUri, isAutoStartup, isRunning, setAutoStartup, setPhase, start, startInternal, stop, stop, stopInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyWebSocketConnectionManager

public ProxyWebSocketConnectionManager(org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate,
                                       org.springframework.web.socket.messaging.WebSocketStompClient stompClient,
                                       org.springframework.web.socket.WebSocketSession userAgentSession,
                                       WebSocketHttpHeadersCallback httpHeadersCallback,
                                       String uri)

Method Detail

errorHandler

public void errorHandler(org.springframework.util.ErrorHandler errorHandler)

openConnection

protected void openConnection()

Specified by:

openConnection in class org.springframework.web.socket.client.ConnectionManagerSupport

connect

public void connect()

reconnect

public void reconnect(long delay)

closeConnection

protected void closeConnection()
                        throws Exception

Specified by:

closeConnection in class org.springframework.web.socket.client.ConnectionManagerSupport

Throws:

Exception

isConnected

protected boolean isConnected()

Specified by:

isConnected in class org.springframework.web.socket.client.ConnectionManagerSupport

afterConnected

public void afterConnected(org.springframework.messaging.simp.stomp.StompSession session,
                           org.springframework.messaging.simp.stomp.StompHeaders connectedHeaders)

Specified by:

afterConnected in interface org.springframework.messaging.simp.stomp.StompSessionHandler

handleException

public void handleException(org.springframework.messaging.simp.stomp.StompSession session,
                            org.springframework.messaging.simp.stomp.StompCommand command,
                            org.springframework.messaging.simp.stomp.StompHeaders headers,
                            byte[] payload,
                            Throwable ex)

Specified by:

handleException in interface org.springframework.messaging.simp.stomp.StompSessionHandler

handleTransportError

public void handleTransportError(org.springframework.messaging.simp.stomp.StompSession session,
                                 Throwable ex)

Specified by:

handleTransportError in interface org.springframework.messaging.simp.stomp.StompSessionHandler

getPayloadType

public Type getPayloadType(org.springframework.messaging.simp.stomp.StompHeaders headers)

Specified by:

getPayloadType in interface org.springframework.messaging.simp.stomp.StompFrameHandler

sendMessage

public void sendMessage(String destination,
                        Object msg)

handleFrame

public void handleFrame(org.springframework.messaging.simp.stomp.StompHeaders headers,
                        Object payload)

Specified by:

handleFrame in interface org.springframework.messaging.simp.stomp.StompFrameHandler

subscribe

public void subscribe(String destination)
               throws Exception

Throws:

Exception

unsubscribe

public void unsubscribe(String destination)

isConnectedToUserAgent

public boolean isConnectedToUserAgent()

disconnect

public void disconnect()