java.io.Closeable
, java.lang.AutoCloseable
, javax.websocket.Session
public final class UndertowSession
extends java.lang.Object
implements javax.websocket.Session
Session
implementation which makes use of the high-level WebSocket API of undertow under the hood.Modifier and Type | Method | Description |
---|---|---|
<T> void |
addMessageHandler(java.lang.Class<T> clazz,
javax.websocket.MessageHandler.Partial<T> handler) |
|
<T> void |
addMessageHandler(java.lang.Class<T> clazz,
javax.websocket.MessageHandler.Whole<T> handler) |
|
void |
addMessageHandler(javax.websocket.MessageHandler messageHandler) |
|
void |
close() |
|
void |
close(javax.websocket.CloseReason closeReason) |
|
void |
closeInternal() |
|
void |
closeInternal(javax.websocket.CloseReason closeReason) |
|
void |
forceClose() |
|
javax.websocket.RemoteEndpoint.Async |
getAsyncRemote() |
|
javax.websocket.RemoteEndpoint.Basic |
getBasicRemote() |
|
ServerWebSocketContainer |
getContainer() |
|
Encoding |
getEncoding() |
|
java.util.concurrent.Executor |
getExecutor() |
|
java.lang.String |
getId() |
|
int |
getMaxBinaryMessageBufferSize() |
|
long |
getMaxIdleTimeout() |
|
int |
getMaxTextMessageBufferSize() |
|
java.util.Set<javax.websocket.MessageHandler> |
getMessageHandlers() |
|
java.util.List<javax.websocket.Extension> |
getNegotiatedExtensions() |
|
java.lang.String |
getNegotiatedSubprotocol() |
|
java.util.Set<javax.websocket.Session> |
getOpenSessions() |
|
java.util.Map<java.lang.String,java.lang.String> |
getPathParameters() |
|
java.lang.String |
getProtocolVersion() |
|
java.lang.String |
getQueryString() |
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getRequestParameterMap() |
|
java.net.URI |
getRequestURI() |
|
java.security.Principal |
getUserPrincipal() |
|
java.util.Map<java.lang.String,java.lang.Object> |
getUserProperties() |
|
io.undertow.websockets.core.WebSocketChannel |
getWebSocketChannel() |
|
boolean |
isOpen() |
|
boolean |
isSecure() |
|
void |
removeMessageHandler(javax.websocket.MessageHandler messageHandler) |
|
void |
setMaxBinaryMessageBufferSize(int i) |
|
void |
setMaxIdleTimeout(long milliseconds) |
|
void |
setMaxTextMessageBufferSize(int i) |
|
void |
setReceiveListener(org.xnio.ChannelListener<io.undertow.websockets.core.WebSocketChannel> handler) |
sets the recieve listener This should only be used for annotated endpoints.
|
public ServerWebSocketContainer getContainer()
getContainer
in interface javax.websocket.Session
public void addMessageHandler(javax.websocket.MessageHandler messageHandler) throws java.lang.IllegalStateException
addMessageHandler
in interface javax.websocket.Session
java.lang.IllegalStateException
public <T> void addMessageHandler(java.lang.Class<T> clazz, javax.websocket.MessageHandler.Whole<T> handler)
addMessageHandler
in interface javax.websocket.Session
public <T> void addMessageHandler(java.lang.Class<T> clazz, javax.websocket.MessageHandler.Partial<T> handler)
addMessageHandler
in interface javax.websocket.Session
public java.util.Set<javax.websocket.MessageHandler> getMessageHandlers()
getMessageHandlers
in interface javax.websocket.Session
public void removeMessageHandler(javax.websocket.MessageHandler messageHandler)
removeMessageHandler
in interface javax.websocket.Session
public void setReceiveListener(org.xnio.ChannelListener<io.undertow.websockets.core.WebSocketChannel> handler)
handler
- The handlerpublic java.lang.String getProtocolVersion()
getProtocolVersion
in interface javax.websocket.Session
public java.lang.String getNegotiatedSubprotocol()
getNegotiatedSubprotocol
in interface javax.websocket.Session
public boolean isSecure()
isSecure
in interface javax.websocket.Session
public boolean isOpen()
isOpen
in interface javax.websocket.Session
public long getMaxIdleTimeout()
getMaxIdleTimeout
in interface javax.websocket.Session
public void setMaxIdleTimeout(long milliseconds)
setMaxIdleTimeout
in interface javax.websocket.Session
public java.lang.String getId()
getId
in interface javax.websocket.Session
public void close() throws java.io.IOException
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in interface javax.websocket.Session
java.io.IOException
public void close(javax.websocket.CloseReason closeReason) throws java.io.IOException
close
in interface javax.websocket.Session
java.io.IOException
public void closeInternal() throws java.io.IOException
java.io.IOException
public void closeInternal(javax.websocket.CloseReason closeReason) throws java.io.IOException
java.io.IOException
public void forceClose()
public java.net.URI getRequestURI()
getRequestURI
in interface javax.websocket.Session
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getRequestParameterMap()
getRequestParameterMap
in interface javax.websocket.Session
public java.lang.String getQueryString()
getQueryString
in interface javax.websocket.Session
public java.util.Map<java.lang.String,java.lang.String> getPathParameters()
getPathParameters
in interface javax.websocket.Session
public java.util.Map<java.lang.String,java.lang.Object> getUserProperties()
getUserProperties
in interface javax.websocket.Session
public java.security.Principal getUserPrincipal()
getUserPrincipal
in interface javax.websocket.Session
public void setMaxBinaryMessageBufferSize(int i)
setMaxBinaryMessageBufferSize
in interface javax.websocket.Session
public int getMaxBinaryMessageBufferSize()
getMaxBinaryMessageBufferSize
in interface javax.websocket.Session
public void setMaxTextMessageBufferSize(int i)
setMaxTextMessageBufferSize
in interface javax.websocket.Session
public int getMaxTextMessageBufferSize()
getMaxTextMessageBufferSize
in interface javax.websocket.Session
public javax.websocket.RemoteEndpoint.Async getAsyncRemote()
getAsyncRemote
in interface javax.websocket.Session
public javax.websocket.RemoteEndpoint.Basic getBasicRemote()
getBasicRemote
in interface javax.websocket.Session
public java.util.Set<javax.websocket.Session> getOpenSessions()
getOpenSessions
in interface javax.websocket.Session
public java.util.List<javax.websocket.Extension> getNegotiatedExtensions()
getNegotiatedExtensions
in interface javax.websocket.Session
public Encoding getEncoding()
public io.undertow.websockets.core.WebSocketChannel getWebSocketChannel()
public java.util.concurrent.Executor getExecutor()
Copyright © 2018. All rights reserved.