java.io.Closeable, java.lang.AutoCloseable, javax.websocket.Sessionpublic 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.Sessionpublic void addMessageHandler(javax.websocket.MessageHandler messageHandler)
throws java.lang.IllegalStateException
addMessageHandler in interface javax.websocket.Sessionjava.lang.IllegalStateExceptionpublic <T> void addMessageHandler(java.lang.Class<T> clazz,
javax.websocket.MessageHandler.Whole<T> handler)
addMessageHandler in interface javax.websocket.Sessionpublic <T> void addMessageHandler(java.lang.Class<T> clazz,
javax.websocket.MessageHandler.Partial<T> handler)
addMessageHandler in interface javax.websocket.Sessionpublic java.util.Set<javax.websocket.MessageHandler> getMessageHandlers()
getMessageHandlers in interface javax.websocket.Sessionpublic void removeMessageHandler(javax.websocket.MessageHandler messageHandler)
removeMessageHandler in interface javax.websocket.Sessionpublic void setReceiveListener(org.xnio.ChannelListener<io.undertow.websockets.core.WebSocketChannel> handler)
handler - The handlerpublic java.lang.String getProtocolVersion()
getProtocolVersion in interface javax.websocket.Sessionpublic java.lang.String getNegotiatedSubprotocol()
getNegotiatedSubprotocol in interface javax.websocket.Sessionpublic boolean isSecure()
isSecure in interface javax.websocket.Sessionpublic boolean isOpen()
isOpen in interface javax.websocket.Sessionpublic long getMaxIdleTimeout()
getMaxIdleTimeout in interface javax.websocket.Sessionpublic void setMaxIdleTimeout(long milliseconds)
setMaxIdleTimeout in interface javax.websocket.Sessionpublic java.lang.String getId()
getId in interface javax.websocket.Sessionpublic void close()
throws java.io.IOException
close in interface java.lang.AutoCloseableclose in interface java.io.Closeableclose in interface javax.websocket.Sessionjava.io.IOExceptionpublic void close(javax.websocket.CloseReason closeReason)
throws java.io.IOException
close in interface javax.websocket.Sessionjava.io.IOExceptionpublic void closeInternal()
throws java.io.IOException
java.io.IOExceptionpublic void closeInternal(javax.websocket.CloseReason closeReason)
throws java.io.IOException
java.io.IOExceptionpublic void forceClose()
public java.net.URI getRequestURI()
getRequestURI in interface javax.websocket.Sessionpublic java.util.Map<java.lang.String,java.util.List<java.lang.String>> getRequestParameterMap()
getRequestParameterMap in interface javax.websocket.Sessionpublic java.lang.String getQueryString()
getQueryString in interface javax.websocket.Sessionpublic java.util.Map<java.lang.String,java.lang.String> getPathParameters()
getPathParameters in interface javax.websocket.Sessionpublic java.util.Map<java.lang.String,java.lang.Object> getUserProperties()
getUserProperties in interface javax.websocket.Sessionpublic java.security.Principal getUserPrincipal()
getUserPrincipal in interface javax.websocket.Sessionpublic void setMaxBinaryMessageBufferSize(int i)
setMaxBinaryMessageBufferSize in interface javax.websocket.Sessionpublic int getMaxBinaryMessageBufferSize()
getMaxBinaryMessageBufferSize in interface javax.websocket.Sessionpublic void setMaxTextMessageBufferSize(int i)
setMaxTextMessageBufferSize in interface javax.websocket.Sessionpublic int getMaxTextMessageBufferSize()
getMaxTextMessageBufferSize in interface javax.websocket.Sessionpublic javax.websocket.RemoteEndpoint.Async getAsyncRemote()
getAsyncRemote in interface javax.websocket.Sessionpublic javax.websocket.RemoteEndpoint.Basic getBasicRemote()
getBasicRemote in interface javax.websocket.Sessionpublic java.util.Set<javax.websocket.Session> getOpenSessions()
getOpenSessions in interface javax.websocket.Sessionpublic java.util.List<javax.websocket.Extension> getNegotiatedExtensions()
getNegotiatedExtensions in interface javax.websocket.Sessionpublic Encoding getEncoding()
public io.undertow.websockets.core.WebSocketChannel getWebSocketChannel()
public java.util.concurrent.Executor getExecutor()
Copyright © 2018. All rights reserved.