org.springframework.integration.stomp

Class WebSocketStompSessionManager

java.lang.Object

org.springframework.integration.stomp.AbstractStompSessionManager

org.springframework.integration.stomp.WebSocketStompSessionManager

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, StompSessionManager

public class WebSocketStompSessionManager
extends AbstractStompSessionManager

The WebSocketStompClient based AbstractStompSessionManager implementation.

Since:

4.2

Author:

Artem Bilan, Sean Mills

See Also:

WebSocketStompClient

Field Summary

Fields inherited from class org.springframework.integration.stomp.AbstractStompSessionManager

logger, stompClient

Constructor Summary

Constructors

Constructor and Description
WebSocketStompSessionManager(org.springframework.web.socket.messaging.WebSocketStompClient webSocketStompClient, java.lang.String url, java.lang.Object... uriVariables)

Method Summary

Modifier and Type	Method and Description
protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession>	doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)
void	setHandshakeHeaders(org.springframework.web.socket.WebSocketHttpHeaders handshakeHeaders)

Methods inherited from class org.springframework.integration.stomp.AbstractStompSessionManager

connect, destroy, disconnect, getConnectHeaders, getPhase, getRecoveryInterval, isAutoReceiptEnabled, isAutoStartup, isConnected, isRunning, setApplicationEventPublisher, setAutoReceipt, setAutoStartup, setBeanName, setConnectHeaders, setPhase, setRecoveryInterval, start, stop, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketStompSessionManager

public WebSocketStompSessionManager(org.springframework.web.socket.messaging.WebSocketStompClient webSocketStompClient,
                                    java.lang.String url,
                                    java.lang.Object... uriVariables)

Method Detail

setHandshakeHeaders

public void setHandshakeHeaders(org.springframework.web.socket.WebSocketHttpHeaders handshakeHeaders)

doConnect

protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession> doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)

Specified by:

doConnect in class AbstractStompSessionManager