Class WebSocketUpgradeRequest
- java.lang.Object
-
- org.eclipse.jetty.client.HttpRequest
-
- org.eclipse.jetty.websocket.client.WebSocketUpgradeRequest
-
- All Implemented Interfaces:
java.util.EventListener
,org.eclipse.jetty.client.api.Request
,org.eclipse.jetty.client.api.Response.CompleteListener
,org.eclipse.jetty.client.api.Response.ResponseListener
,org.eclipse.jetty.client.http.HttpConnectionUpgrader
public class WebSocketUpgradeRequest extends org.eclipse.jetty.client.HttpRequest implements org.eclipse.jetty.client.api.Response.CompleteListener, org.eclipse.jetty.client.http.HttpConnectionUpgrader
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
WebSocketUpgradeRequest.ClientUpgradeRequestFacade
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.client.api.Request
org.eclipse.jetty.client.api.Request.BeginListener, org.eclipse.jetty.client.api.Request.CommitListener, org.eclipse.jetty.client.api.Request.ContentListener, org.eclipse.jetty.client.api.Request.FailureListener, org.eclipse.jetty.client.api.Request.HeadersListener, org.eclipse.jetty.client.api.Request.Listener, org.eclipse.jetty.client.api.Request.QueuedListener, org.eclipse.jetty.client.api.Request.RequestListener, org.eclipse.jetty.client.api.Request.SuccessListener
-
-
Field Summary
Fields Modifier and Type Field Description private WebSocketUpgradeRequest.ClientUpgradeRequestFacade
apiRequestFacade
WebSocket API UpgradeRequest Facade to HttpClient HttpRequestprivate java.util.concurrent.CompletableFuture<Session>
fut
private EventDriver
localEndpoint
private static org.eclipse.jetty.util.log.Logger
LOG
private UpgradeListener
upgradeListener
private WebSocketClient
wsClient
-
Constructor Summary
Constructors Modifier Constructor Description WebSocketUpgradeRequest(WebSocketClient wsClient, org.eclipse.jetty.client.HttpClient httpClient, java.net.URI wsURI, java.lang.Object localEndpoint)
Initiating a WebSocket Upgrade using HTTP/1.1protected
WebSocketUpgradeRequest(WebSocketClient wsClient, org.eclipse.jetty.client.HttpClient httpClient, ClientUpgradeRequest request)
Exists for internal use of HttpClient by WebSocketClient.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private java.lang.String
genRandomKey()
private ExtensionFactory
getExtensionFactory()
private org.eclipse.jetty.http.HttpFields
getHttpFields()
private SessionFactory
getSessionFactory()
private void
handleException(java.lang.Throwable failure)
private void
initWebSocketHeaders()
void
onComplete(org.eclipse.jetty.client.api.Result result)
org.eclipse.jetty.client.api.ContentResponse
send()
void
send(org.eclipse.jetty.client.api.Response.CompleteListener listener)
java.util.concurrent.CompletableFuture<Session>
sendAsync()
void
setUpgradeListener(UpgradeListener upgradeListener)
void
upgrade(org.eclipse.jetty.client.HttpResponse response, org.eclipse.jetty.client.http.HttpConnectionOverHTTP oldConn)
-
Methods inherited from class org.eclipse.jetty.client.HttpRequest
abort, accept, agent, attribute, content, content, cookie, file, file, followRedirects, getAbortCause, getAgent, getAttributes, getContent, getConversation, getCookies, getHeaders, getHost, getIdleTimeout, getMethod, getParams, getPath, getPort, getPushListener, getQuery, getRequestListeners, getResponseListeners, getScheme, getTag, getTimeout, getTrailers, getURI, getVersion, header, header, host, idleTimeout, isFollowRedirects, listener, method, method, onComplete, onRequestBegin, onRequestCommit, onRequestContent, onRequestFailure, onRequestHeaders, onRequestQueued, onRequestSuccess, onResponseBegin, onResponseContent, onResponseContentAsync, onResponseContentDemanded, onResponseFailure, onResponseHeader, onResponseHeaders, onResponseSuccess, param, path, port, pushListener, scheme, tag, timeout, toString, trailers, version
-
-
-
-
Field Detail
-
LOG
private static final org.eclipse.jetty.util.log.Logger LOG
-
wsClient
private final WebSocketClient wsClient
-
localEndpoint
private final EventDriver localEndpoint
-
fut
private final java.util.concurrent.CompletableFuture<Session> fut
-
apiRequestFacade
private final WebSocketUpgradeRequest.ClientUpgradeRequestFacade apiRequestFacade
WebSocket API UpgradeRequest Facade to HttpClient HttpRequest
-
upgradeListener
private UpgradeListener upgradeListener
-
-
Constructor Detail
-
WebSocketUpgradeRequest
protected WebSocketUpgradeRequest(WebSocketClient wsClient, org.eclipse.jetty.client.HttpClient httpClient, ClientUpgradeRequest request)
Exists for internal use of HttpClient by WebSocketClient.Maintained for Backward compatibility and also for JSR356 WebSocket ClientContainer use.
- Parameters:
wsClient
- the WebSocketClient that this request useshttpClient
- the HttpClient that this request usesrequest
- the ClientUpgradeRequest (backward compat) to base this request from
-
WebSocketUpgradeRequest
public WebSocketUpgradeRequest(WebSocketClient wsClient, org.eclipse.jetty.client.HttpClient httpClient, java.net.URI wsURI, java.lang.Object localEndpoint)
Initiating a WebSocket Upgrade using HTTP/1.1- Parameters:
wsClient
- the WebSocketClient that this request useshttpClient
- the HttpClient that this request useslocalEndpoint
- the local endpoint (following Jetty WebSocket Client API rules) to use for incoming WebSocket eventswsURI
- the WebSocket URI to connect to
-
-
Method Detail
-
genRandomKey
private java.lang.String genRandomKey()
-
getExtensionFactory
private ExtensionFactory getExtensionFactory()
-
getSessionFactory
private SessionFactory getSessionFactory()
-
initWebSocketHeaders
private void initWebSocketHeaders()
-
onComplete
public void onComplete(org.eclipse.jetty.client.api.Result result)
- Specified by:
onComplete
in interfaceorg.eclipse.jetty.client.api.Response.CompleteListener
-
handleException
private void handleException(java.lang.Throwable failure)
-
send
public org.eclipse.jetty.client.api.ContentResponse send() throws java.lang.InterruptedException, java.util.concurrent.TimeoutException, java.util.concurrent.ExecutionException
- Specified by:
send
in interfaceorg.eclipse.jetty.client.api.Request
- Overrides:
send
in classorg.eclipse.jetty.client.HttpRequest
- Throws:
java.lang.InterruptedException
java.util.concurrent.TimeoutException
java.util.concurrent.ExecutionException
-
send
public void send(org.eclipse.jetty.client.api.Response.CompleteListener listener)
- Specified by:
send
in interfaceorg.eclipse.jetty.client.api.Request
- Overrides:
send
in classorg.eclipse.jetty.client.HttpRequest
-
sendAsync
public java.util.concurrent.CompletableFuture<Session> sendAsync()
-
upgrade
public void upgrade(org.eclipse.jetty.client.HttpResponse response, org.eclipse.jetty.client.http.HttpConnectionOverHTTP oldConn)
- Specified by:
upgrade
in interfaceorg.eclipse.jetty.client.http.HttpConnectionUpgrader
-
setUpgradeListener
public void setUpgradeListener(UpgradeListener upgradeListener)
-
getHttpFields
private org.eclipse.jetty.http.HttpFields getHttpFields()
-
-