Package io.undertow.servlet.websockets
Class ServletWebSocketHttpExchange
- java.lang.Object
-
- io.undertow.servlet.websockets.ServletWebSocketHttpExchange
-
- All Implemented Interfaces:
io.undertow.websockets.spi.WebSocketHttpExchange,Closeable,AutoCloseable
public class ServletWebSocketHttpExchange extends Object implements io.undertow.websockets.spi.WebSocketHttpExchange
- Author:
- Stuart Douglas
-
-
Constructor Summary
Constructors Constructor Description ServletWebSocketHttpExchange(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Set<io.undertow.websockets.core.WebSocketChannel> peerConnections)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidendExchange()<T> TgetAttachment(io.undertow.util.AttachmentKey<T> key)io.undertow.connector.ByteBufferPoolgetBufferPool()org.xnio.OptionMapgetOptions()Set<io.undertow.websockets.core.WebSocketChannel>getPeerConnections()StringgetQueryString()StringgetRequestHeader(String headerName)Map<String,List<String>>getRequestHeaders()Map<String,List<String>>getRequestParameters()StringgetRequestScheme()StringgetRequestURI()StringgetResponseHeader(String headerName)Map<String,List<String>>getResponseHeaders()ObjectgetSession()PrincipalgetUserPrincipal()booleanisUserInRole(String role)<T> voidputAttachment(io.undertow.util.AttachmentKey<T> key, T value)org.xnio.IoFuture<byte[]>readRequestData()org.xnio.IoFuture<Void>sendData(ByteBuffer data)voidsetResponseHeader(String headerName, String headerValue)voidsetResponseHeaders(Map<String,List<String>> headers)voidupgradeChannel(io.undertow.server.HttpUpgradeListener upgradeCallback)
-
-
-
Constructor Detail
-
ServletWebSocketHttpExchange
public ServletWebSocketHttpExchange(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Set<io.undertow.websockets.core.WebSocketChannel> peerConnections)
-
-
Method Detail
-
putAttachment
public <T> void putAttachment(io.undertow.util.AttachmentKey<T> key, T value)- Specified by:
putAttachmentin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getAttachment
public <T> T getAttachment(io.undertow.util.AttachmentKey<T> key)
- Specified by:
getAttachmentin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getRequestHeader
public String getRequestHeader(String headerName)
- Specified by:
getRequestHeaderin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getRequestHeaders
public Map<String,List<String>> getRequestHeaders()
- Specified by:
getRequestHeadersin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getResponseHeader
public String getResponseHeader(String headerName)
- Specified by:
getResponseHeaderin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getResponseHeaders
public Map<String,List<String>> getResponseHeaders()
- Specified by:
getResponseHeadersin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
setResponseHeaders
public void setResponseHeaders(Map<String,List<String>> headers)
- Specified by:
setResponseHeadersin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
setResponseHeader
public void setResponseHeader(String headerName, String headerValue)
- Specified by:
setResponseHeaderin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
upgradeChannel
public void upgradeChannel(io.undertow.server.HttpUpgradeListener upgradeCallback)
- Specified by:
upgradeChannelin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
sendData
public org.xnio.IoFuture<Void> sendData(ByteBuffer data)
- Specified by:
sendDatain interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
readRequestData
public org.xnio.IoFuture<byte[]> readRequestData()
- Specified by:
readRequestDatain interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
endExchange
public void endExchange()
- Specified by:
endExchangein interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getRequestScheme
public String getRequestScheme()
- Specified by:
getRequestSchemein interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getRequestURI
public String getRequestURI()
- Specified by:
getRequestURIin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getBufferPool
public io.undertow.connector.ByteBufferPool getBufferPool()
- Specified by:
getBufferPoolin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getQueryString
public String getQueryString()
- Specified by:
getQueryStringin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getSession
public Object getSession()
- Specified by:
getSessionin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getRequestParameters
public Map<String,List<String>> getRequestParameters()
- Specified by:
getRequestParametersin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getUserPrincipal
public Principal getUserPrincipal()
- Specified by:
getUserPrincipalin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
isUserInRole
public boolean isUserInRole(String role)
- Specified by:
isUserInRolein interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getPeerConnections
public Set<io.undertow.websockets.core.WebSocketChannel> getPeerConnections()
- Specified by:
getPeerConnectionsin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
getOptions
public org.xnio.OptionMap getOptions()
- Specified by:
getOptionsin interfaceio.undertow.websockets.spi.WebSocketHttpExchange
-
-