Package io.undertow.websockets.jsr
Class UndertowSession
java.lang.Object
io.undertow.websockets.jsr.UndertowSession
- All Implemented Interfaces:
Closeable
,AutoCloseable
,javax.websocket.Session
Session
implementation which makes use of the high-level WebSocket API of undertow under the hood.- Author:
- Norman Maurer
-
Method Summary
Modifier and TypeMethodDescription<T> void
addMessageHandler
(Class<T> clazz, javax.websocket.MessageHandler.Partial<T> handler) <T> void
addMessageHandler
(Class<T> clazz, javax.websocket.MessageHandler.Whole<T> handler) void
addMessageHandler
(javax.websocket.MessageHandler messageHandler) void
close()
void
close
(javax.websocket.CloseReason closeReason) void
void
closeInternal
(javax.websocket.CloseReason closeReason) void
javax.websocket.RemoteEndpoint.Async
javax.websocket.RemoteEndpoint.Basic
getId()
int
long
int
Set<javax.websocket.MessageHandler>
List<javax.websocket.Extension>
Set<javax.websocket.Session>
io.undertow.websockets.core.WebSocketChannel
boolean
isOpen()
boolean
isSecure()
void
removeMessageHandler
(javax.websocket.MessageHandler messageHandler) void
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.
-
Method Details
-
getContainer
- Specified by:
getContainer
in interfacejavax.websocket.Session
-
addMessageHandler
public void addMessageHandler(javax.websocket.MessageHandler messageHandler) throws IllegalStateException - Specified by:
addMessageHandler
in interfacejavax.websocket.Session
- Throws:
IllegalStateException
-
addMessageHandler
- Specified by:
addMessageHandler
in interfacejavax.websocket.Session
-
addMessageHandler
public <T> void addMessageHandler(Class<T> clazz, javax.websocket.MessageHandler.Partial<T> handler) - Specified by:
addMessageHandler
in interfacejavax.websocket.Session
-
getMessageHandlers
- Specified by:
getMessageHandlers
in interfacejavax.websocket.Session
-
removeMessageHandler
public void removeMessageHandler(javax.websocket.MessageHandler messageHandler) - Specified by:
removeMessageHandler
in interfacejavax.websocket.Session
-
setReceiveListener
public void setReceiveListener(org.xnio.ChannelListener<io.undertow.websockets.core.WebSocketChannel> handler) sets the recieve listener This should only be used for annotated endpoints.- Parameters:
handler
- The handler
-
getProtocolVersion
- Specified by:
getProtocolVersion
in interfacejavax.websocket.Session
-
getNegotiatedSubprotocol
- Specified by:
getNegotiatedSubprotocol
in interfacejavax.websocket.Session
-
isSecure
public boolean isSecure()- Specified by:
isSecure
in interfacejavax.websocket.Session
-
isOpen
public boolean isOpen()- Specified by:
isOpen
in interfacejavax.websocket.Session
-
getMaxIdleTimeout
public long getMaxIdleTimeout()- Specified by:
getMaxIdleTimeout
in interfacejavax.websocket.Session
-
setMaxIdleTimeout
public void setMaxIdleTimeout(long milliseconds) - Specified by:
setMaxIdleTimeout
in interfacejavax.websocket.Session
-
getId
- Specified by:
getId
in interfacejavax.websocket.Session
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfacejavax.websocket.Session
- Throws:
IOException
-
close
- Specified by:
close
in interfacejavax.websocket.Session
- Throws:
IOException
-
closeInternal
- Throws:
IOException
-
closeInternal
- Throws:
IOException
-
forceClose
public void forceClose() -
getRequestURI
- Specified by:
getRequestURI
in interfacejavax.websocket.Session
-
getRequestParameterMap
- Specified by:
getRequestParameterMap
in interfacejavax.websocket.Session
-
getQueryString
- Specified by:
getQueryString
in interfacejavax.websocket.Session
-
getPathParameters
- Specified by:
getPathParameters
in interfacejavax.websocket.Session
-
getUserProperties
- Specified by:
getUserProperties
in interfacejavax.websocket.Session
-
getUserPrincipal
- Specified by:
getUserPrincipal
in interfacejavax.websocket.Session
-
setMaxBinaryMessageBufferSize
public void setMaxBinaryMessageBufferSize(int i) - Specified by:
setMaxBinaryMessageBufferSize
in interfacejavax.websocket.Session
-
getMaxBinaryMessageBufferSize
public int getMaxBinaryMessageBufferSize()- Specified by:
getMaxBinaryMessageBufferSize
in interfacejavax.websocket.Session
-
setMaxTextMessageBufferSize
public void setMaxTextMessageBufferSize(int i) - Specified by:
setMaxTextMessageBufferSize
in interfacejavax.websocket.Session
-
getMaxTextMessageBufferSize
public int getMaxTextMessageBufferSize()- Specified by:
getMaxTextMessageBufferSize
in interfacejavax.websocket.Session
-
getAsyncRemote
public javax.websocket.RemoteEndpoint.Async getAsyncRemote()- Specified by:
getAsyncRemote
in interfacejavax.websocket.Session
-
getBasicRemote
public javax.websocket.RemoteEndpoint.Basic getBasicRemote()- Specified by:
getBasicRemote
in interfacejavax.websocket.Session
-
getOpenSessions
- Specified by:
getOpenSessions
in interfacejavax.websocket.Session
-
getNegotiatedExtensions
- Specified by:
getNegotiatedExtensions
in interfacejavax.websocket.Session
-
getEncoding
-
getWebSocketChannel
public io.undertow.websockets.core.WebSocketChannel getWebSocketChannel() -
getExecutor
-