WebSocketHttpExchange
, java.io.Closeable
, java.lang.AutoCloseable
BlockingWebSocketHttpServerExchange
public class AsyncWebSocketHttpServerExchange extends java.lang.Object implements WebSocketHttpExchange
Constructor | Description |
---|---|
AsyncWebSocketHttpServerExchange(HttpServerExchange exchange,
java.util.Set<WebSocketChannel> peerConnections) |
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
Forcibly close the exchange.
|
void |
endExchange() |
End the exchange normally.
|
<T> T |
getAttachment(AttachmentKey<T> key) |
|
ByteBufferPool |
getBufferPool() |
|
org.xnio.OptionMap |
getOptions() |
|
java.util.Set<WebSocketChannel> |
getPeerConnections() |
|
java.lang.String |
getQueryString() |
|
java.lang.String |
getRequestHeader(java.lang.String headerName) |
gets the first request header with the specified name
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getRequestHeaders() |
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getRequestParameters() |
|
java.lang.String |
getRequestScheme() |
Get the request scheme, usually http or https
|
java.lang.String |
getRequestURI() |
|
java.lang.String |
getResponseHeader(java.lang.String headerName) |
get a response header
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getResponseHeaders() |
|
java.lang.Object |
getSession() |
Gets the session, if any
|
java.security.Principal |
getUserPrincipal() |
|
boolean |
isUserInRole(java.lang.String role) |
|
<T> void |
putAttachment(AttachmentKey<T> key,
T value) |
|
org.xnio.IoFuture<byte[]> |
readRequestData() |
Gets the body of the request.
|
org.xnio.IoFuture<java.lang.Void> |
sendData(java.nio.ByteBuffer data) |
Send some data
|
void |
setResponseHeader(java.lang.String headerName,
java.lang.String headerValue) |
Set a response header
|
void |
setResponseHeaders(java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers) |
Sets the response headers
|
void |
upgradeChannel(HttpUpgradeListener upgradeCallback) |
Upgrade the underlying channel
|
public AsyncWebSocketHttpServerExchange(HttpServerExchange exchange, java.util.Set<WebSocketChannel> peerConnections)
public <T> void putAttachment(AttachmentKey<T> key, T value)
putAttachment
in interface WebSocketHttpExchange
public <T> T getAttachment(AttachmentKey<T> key)
getAttachment
in interface WebSocketHttpExchange
public java.lang.String getRequestHeader(java.lang.String headerName)
WebSocketHttpExchange
getRequestHeader
in interface WebSocketHttpExchange
headerName
- The header namepublic java.util.Map<java.lang.String,java.util.List<java.lang.String>> getRequestHeaders()
getRequestHeaders
in interface WebSocketHttpExchange
public java.lang.String getResponseHeader(java.lang.String headerName)
WebSocketHttpExchange
getResponseHeader
in interface WebSocketHttpExchange
headerName
- The header namepublic java.util.Map<java.lang.String,java.util.List<java.lang.String>> getResponseHeaders()
getResponseHeaders
in interface WebSocketHttpExchange
public void setResponseHeaders(java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers)
WebSocketHttpExchange
setResponseHeaders
in interface WebSocketHttpExchange
public void setResponseHeader(java.lang.String headerName, java.lang.String headerValue)
WebSocketHttpExchange
setResponseHeader
in interface WebSocketHttpExchange
headerName
- The header nameheaderValue
- The header valuepublic void upgradeChannel(HttpUpgradeListener upgradeCallback)
WebSocketHttpExchange
upgradeChannel
in interface WebSocketHttpExchange
public org.xnio.IoFuture<java.lang.Void> sendData(java.nio.ByteBuffer data)
WebSocketHttpExchange
sendData
in interface WebSocketHttpExchange
data
- The datapublic org.xnio.IoFuture<byte[]> readRequestData()
WebSocketHttpExchange
readRequestData
in interface WebSocketHttpExchange
public void endExchange()
WebSocketHttpExchange
endExchange
in interface WebSocketHttpExchange
public void close()
WebSocketHttpExchange
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in interface WebSocketHttpExchange
public java.lang.String getRequestScheme()
WebSocketHttpExchange
getRequestScheme
in interface WebSocketHttpExchange
public java.lang.String getRequestURI()
getRequestURI
in interface WebSocketHttpExchange
public ByteBufferPool getBufferPool()
getBufferPool
in interface WebSocketHttpExchange
public java.lang.String getQueryString()
getQueryString
in interface WebSocketHttpExchange
public java.lang.Object getSession()
WebSocketHttpExchange
getSession
in interface WebSocketHttpExchange
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getRequestParameters()
getRequestParameters
in interface WebSocketHttpExchange
public java.security.Principal getUserPrincipal()
getUserPrincipal
in interface WebSocketHttpExchange
public boolean isUserInRole(java.lang.String role)
isUserInRole
in interface WebSocketHttpExchange
public java.util.Set<WebSocketChannel> getPeerConnections()
getPeerConnections
in interface WebSocketHttpExchange
public org.xnio.OptionMap getOptions()
getOptions
in interface WebSocketHttpExchange
Copyright © 2018. All rights reserved.