diff --git a/jetty-spdy/spdy-http-server/src/main/java/org/eclipse/jetty/spdy/server/http/HttpTransportOverSPDY.java b/jetty-spdy/spdy-http-server/src/main/java/org/eclipse/jetty/spdy/server/http/HttpTransportOverSPDY.java index b67bfffaa37..fc83aef1f44 100644 --- a/jetty-spdy/spdy-http-server/src/main/java/org/eclipse/jetty/spdy/server/http/HttpTransportOverSPDY.java +++ b/jetty-spdy/spdy-http-server/src/main/java/org/eclipse/jetty/spdy/server/http/HttpTransportOverSPDY.java @@ -23,7 +23,6 @@ import java.nio.ByteBuffer; import java.util.Queue; import java.util.Set; import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicBoolean; import org.eclipse.jetty.http.HttpField; @@ -86,14 +85,14 @@ public class HttpTransportOverSPDY implements HttpTransport return requestHeaders; } - + @Override public void send(ByteBuffer responseBodyContent, boolean lastContent, Callback callback) { // TODO can this be more efficient? - send(null,responseBodyContent, lastContent, callback); + send(null, responseBodyContent, lastContent, callback); } - + @Override public void send(HttpGenerator.ResponseInfo info, ByteBuffer content, boolean lastContent, Callback callback) { @@ -306,7 +305,7 @@ public class HttpTransportOverSPDY implements HttpTransport final Fields pushHeaders = createPushHeaders(scheme, host, pushResource); final Fields pushRequestHeaders = createRequestHeaders(scheme, host, uri, pushResource); - stream.push(new PushInfo(pushHeaders, false), new Promise.Adapter() + stream.push(new PushInfo(pushHeaders, false), new Promise() { @Override public void succeeded(Stream pushStream) @@ -315,6 +314,12 @@ public class HttpTransportOverSPDY implements HttpTransport queue.offer(new PushResource(pushStream, pushRequestHeaders)); sendNextResourceData(); } + + @Override + public void failed(Throwable x) + { + LOG.debug("Creating push stream failed.", x); + } }); }