org.springframework.web.socket.sockjs.client

Class JettyXhrTransport.SockJsResponseListener

java.lang.Object

Response.Listener.Adapter

org.springframework.web.socket.sockjs.client.JettyXhrTransport.SockJsResponseListener

Enclosing class:

JettyXhrTransport

private class JettyXhrTransport.SockJsResponseListener
extends Response.Listener.Adapter

Jetty client Response Listener that splits the body of the response into SockJS frames and delegates them to the XhrClientSockJsSession.

Field Summary

Fields

Modifier and Type	Field and Description
private SettableListenableFuture<WebSocketSession>	connectFuture
private java.io.ByteArrayOutputStream	outputStream
private HttpHeaders	receiveHeaders
private XhrClientSockJsSession	sockJsSession
private java.net.URI	transportUrl

Constructor Summary

Constructors

Constructor and Description
SockJsResponseListener(java.net.URI url, HttpHeaders headers, XhrClientSockJsSession sockJsSession, SettableListenableFuture<WebSocketSession> connectFuture)

Method Summary

Modifier and Type	Method and Description
private void	handleFrame()
void	onBegin(Response response)
void	onContent(Response response, java.nio.ByteBuffer buffer)
void	onFailure(Response response, java.lang.Throwable failure)
void	onHeaders(Response response)
void	onSuccess(Response response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

transportUrl

private final java.net.URI transportUrl

receiveHeaders

private final HttpHeaders receiveHeaders

sockJsSession

private final XhrClientSockJsSession sockJsSession

connectFuture

private final SettableListenableFuture<WebSocketSession> connectFuture

outputStream

private final java.io.ByteArrayOutputStream outputStream

Constructor Detail

SockJsResponseListener

public SockJsResponseListener(java.net.URI url,
                              HttpHeaders headers,
                              XhrClientSockJsSession sockJsSession,
                              SettableListenableFuture<WebSocketSession> connectFuture)

Method Detail

onBegin

public void onBegin(Response response)

onHeaders

public void onHeaders(Response response)

onContent

public void onContent(Response response,
                      java.nio.ByteBuffer buffer)

handleFrame

private void handleFrame()

onSuccess

public void onSuccess(Response response)

onFailure

public void onFailure(Response response,
                      java.lang.Throwable failure)