andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[#735] Make sure the handshake ChannelFuture is notified after the right encoder is present in the ChannelPipeline

Browse Source
This commit is contained in:
Norman Maurer 2012-11-13 09:31:34 +01:00
parent a0e9921517
commit 966565d4b9
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/jboss/netty/handler/codec/http/websocketx/WebSocketClientHandshaker00.java
View File

@ -20,7 +20,9 @@ import org.jboss.netty.buffer.ChannelBuffers;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.ChannelFutureListener;
import org.jboss.netty.channel.ChannelFutureNotifier;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.DefaultChannelFuture;
import org.jboss.netty.handler.codec.http.DefaultHttpRequest;
import org.jboss.netty.handler.codec.http.HttpHeaders.Names;
import org.jboss.netty.handler.codec.http.HttpHeaders.Values;
@ -189,6 +191,7 @@ public class WebSocketClientHandshaker00 extends WebSocketClientHandshaker {
request.setContent(ChannelBuffers.copiedBuffer(key3));
ChannelFuture handshakeFuture = new DefaultChannelFuture(channel, false);
ChannelFuture future = channel.write(request);
future.addListener(new ChannelFutureListener() {
@ -197,8 +200,9 @@ public class WebSocketClientHandshaker00 extends WebSocketClientHandshaker {
p.replace(HttpRequestEncoder.class, "ws-encoder", new WebSocket00FrameEncoder());
}
});
future.addListener(new ChannelFutureNotifier(handshakeFuture));
return future;
return handshakeFuture;
}
/**