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.AnnotatedEndpointConnectionManager
logger
Constructor and Description |
---|
EndpointConnectionManager(Class<? extends Endpoint> endpointClass,
String uriTemplate,
Object... uriVars) |
EndpointConnectionManager(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 . |
WebSocketContainer |
getWebSocketContainer() |
protected boolean |
isConnected() |
protected void |
openConnection() |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setConfigurator(ClientEndpointConfig.Configurator configurator) |
void |
setDecoders(List<Class<? extends Decoder>> decoders) |
void |
setEncoders(List<Class<? extends Encoder>> encoders) |
void |
setExtensions(Extension... extensions) |
void |
setSupportedProtocols(String... protocols) |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Set a
TaskExecutor to use to open connections. |
void |
setWebSocketContainer(WebSocketContainer webSocketContainer) |
getPhase, getUri, isAutoStartup, isRunning, setAutoStartup, setPhase, start, startInternal, stop, stop, stopInternal
public EndpointConnectionManager(Endpoint endpoint, String uriTemplate, Object... uriVariables)
public void setSupportedProtocols(String... protocols)
public void setExtensions(Extension... extensions)
public void setConfigurator(ClientEndpointConfig.Configurator configurator)
public void setWebSocketContainer(WebSocketContainer webSocketContainer)
public WebSocketContainer getWebSocketContainer()
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) throws org.springframework.beans.BeansException
setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
org.springframework.beans.BeansException
public 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 ConnectionManagerSupport
protected void closeConnection() throws Exception
closeConnection
in class ConnectionManagerSupport
Exception
protected boolean isConnected()
isConnected
in class ConnectionManagerSupport