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(java.lang.Class<? extends javax.websocket.Endpoint> endpointClass,
java.lang.String uriTemplate,
java.lang.Object... uriVars) |
EndpointConnectionManager(javax.websocket.Endpoint endpoint,
java.lang.String uriTemplate,
java.lang.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(java.util.List<java.lang.Class<? extends javax.websocket.Decoder>> decoders) |
void |
setEncoders(java.util.List<java.lang.Class<? extends javax.websocket.Encoder>> encoders) |
void |
setExtensions(javax.websocket.Extension... extensions) |
void |
setSupportedProtocols(java.lang.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,
java.lang.String uriTemplate,
java.lang.Object... uriVariables)
public EndpointConnectionManager(java.lang.Class<? extends javax.websocket.Endpoint> endpointClass,
java.lang.String uriTemplate,
java.lang.Object... uriVars)
public void setSupportedProtocols(java.lang.String... protocols)
public void setExtensions(javax.websocket.Extension... extensions)
public void setEncoders(java.util.List<java.lang.Class<? extends javax.websocket.Encoder>> encoders)
public void setDecoders(java.util.List<java.lang.Class<? extends javax.websocket.Decoder>> decoders)
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)
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwarepublic 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 java.lang.Exception
closeConnection in class ConnectionManagerSupportjava.lang.Exceptionprotected boolean isConnected()
isConnected in class ConnectionManagerSupport