org.eclipse.jetty.spdy.server.proxy

Class SPDYProxyEngine

java.lang.Object

org.eclipse.jetty.spdy.server.proxy.ProxyEngine

org.eclipse.jetty.spdy.server.proxy.SPDYProxyEngine

All Implemented Interfaces:

EventListener, StreamFrameListener

public class SPDYProxyEngine
extends ProxyEngine
implements StreamFrameListener

SPDYProxyEngine implements a SPDY to SPDY proxy, that is, converts SPDY events received by clients into SPDY events for the servers.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.spdy.api.StreamFrameListener

StreamFrameListener.Adapter

Constructor Summary

Constructors

Constructor and Description
SPDYProxyEngine(SPDYClient.Factory factory)

Method Summary

Methods

Modifier and Type	Method and Description
long	getConnectTimeout()
long	getTimeout()
void	onData(Stream clientStream, DataInfo clientDataInfo) Callback invoked when data bytes are received on a stream.
void	onFailure(Stream stream, Throwable x) Callback invoked on errors.
void	onHeaders(Stream stream, HeadersInfo headersInfo) Callback invoked when headers are received on a stream.
StreamFrameListener	onPush(Stream stream, PushInfo pushInfo) Callback invoked when a push syn has been received on a stream.
void	onReply(Stream stream, ReplyInfo replyInfo) Callback invoked when a reply to a stream creation has been received.
StreamFrameListener	proxy(Stream clientStream, SynInfo clientSynInfo, ProxyEngineSelector.ProxyServerInfo proxyServerInfo)
void	setConnectTimeout(long connectTimeout)
void	setTimeout(long timeout)

Methods inherited from class org.eclipse.jetty.spdy.server.proxy.ProxyEngine

addRequestProxyHeaders, addResponseProxyHeaders, customizeRequestHeaders, customizeResponseHeaders, getName, removeHopHeaders

Methods inherited from class java.lang.Object

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

Constructor Detail

SPDYProxyEngine

public SPDYProxyEngine(SPDYClient.Factory factory)

Method Detail

getConnectTimeout

public long getConnectTimeout()

setConnectTimeout

public void setConnectTimeout(long connectTimeout)

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long timeout)

proxy

public StreamFrameListener proxy(Stream clientStream,
                        SynInfo clientSynInfo,
                        ProxyEngineSelector.ProxyServerInfo proxyServerInfo)

Specified by:

proxy in class ProxyEngine

onPush

public StreamFrameListener onPush(Stream stream,
                         PushInfo pushInfo)

Description copied from interface: StreamFrameListener

Callback invoked when a push syn has been received on a stream.

Specified by:

onPush in interface StreamFrameListener

Parameters:

stream - the push stream just created

pushInfo - the push metadata

Returns:

a listener for stream events or null if there is no interest in being notified of stream events

onReply

public void onReply(Stream stream,
           ReplyInfo replyInfo)

Description copied from interface: StreamFrameListener

Callback invoked when a reply to a stream creation has been received.

Application code may implement this method to send more data to the other end:

 public void onReply(Stream stream, ReplyInfo replyInfo)
 {
     stream.data(new StringDataInfo("content"), true);
 }
 

Specified by:

onReply in interface StreamFrameListener

Parameters:

stream - the stream

replyInfo - the reply metadata

onHeaders

public void onHeaders(Stream stream,
             HeadersInfo headersInfo)

Description copied from interface: StreamFrameListener

Callback invoked when headers are received on a stream.

Specified by:

onHeaders in interface StreamFrameListener

Parameters:

stream - the stream

headersInfo - the headers metadata

onData

public void onData(Stream clientStream,
          DataInfo clientDataInfo)

Description copied from interface: StreamFrameListener

Callback invoked when data bytes are received on a stream.

Implementers should be read or consume the content of the DataInfo before this method returns.

Specified by:

onData in interface StreamFrameListener

Parameters:

clientStream - the stream

clientDataInfo - the data metadata

onFailure

public void onFailure(Stream stream,
             Throwable x)

Description copied from interface: StreamFrameListener

Callback invoked on errors.

Specified by:

onFailure in interface StreamFrameListener

Parameters:

stream - the stream

x - the failure