public class EndpointConnectionManager extends ConnectionManagerSupport implements org.springframework.beans.factory.BeanFactoryAware
Endpoint, connects to a
WebSocket server through the ConnectionManagerSupport.start() and ConnectionManagerSupport.stop() methods. If
ConnectionManagerSupport.setAutoStartup(boolean) is set to true this will be done automatically
when the Spring ApplicationContext is refreshed.AnnotatedEndpointConnectionManagerlogger| Constructor and Description |
|---|
EndpointConnectionManager(Class<? extends javax.websocket.Endpoint> endpointClass,
String uriTemplate,
Object... uriVars) |
EndpointConnectionManager(javax.websocket.Endpoint endpoint,
String uriTemplate,
Object... uriVariables) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
closeConnection() |
org.springframework.core.task.TaskExecutor |
getTaskExecutor()
Return the configured
TaskExecutor. |
javax.websocket.WebSocketContainer |
getWebSocketContainer() |
protected boolean |
isConnected() |
protected void |
openConnection() |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setConfigurator(javax.websocket.ClientEndpointConfig.Configurator configurator) |
void |
setDecoders(List<Class<? extends javax.websocket.Decoder>> decoders) |
void |
setEncoders(List<Class<? extends javax.websocket.Encoder>> encoders) |
void |
setExtensions(javax.websocket.Extension... extensions) |
void |
setSupportedProtocols(String... protocols) |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Set a
TaskExecutor to use to open connections. |
void |
setWebSocketContainer(javax.websocket.WebSocketContainer webSocketContainer) |
getPhase, getUri, isAutoStartup, isRunning, setAutoStartup, setPhase, start, startInternal, stop, stop, stopInternalpublic EndpointConnectionManager(javax.websocket.Endpoint endpoint,
String uriTemplate,
Object... uriVariables)
public void setSupportedProtocols(String... protocols)
public void setExtensions(javax.websocket.Extension... extensions)
public void setConfigurator(javax.websocket.ClientEndpointConfig.Configurator configurator)
public void setWebSocketContainer(javax.websocket.WebSocketContainer webSocketContainer)
public javax.websocket.WebSocketContainer getWebSocketContainer()
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
throws org.springframework.beans.BeansException
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwareorg.springframework.beans.BeansExceptionpublic void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
TaskExecutor to use to open connections.
By default SimpleAsyncTaskExecutor is used.public org.springframework.core.task.TaskExecutor getTaskExecutor()
TaskExecutor.protected void openConnection()
openConnection in class ConnectionManagerSupportprotected void closeConnection()
throws Exception
closeConnection in class ConnectionManagerSupportExceptionprotected boolean isConnected()
isConnected in class ConnectionManagerSupport