diff --git a/core/src/test/java/com/google/bitcoin/core/FakeChannelSink.java b/core/src/test/java/com/google/bitcoin/core/FakeChannelSink.java index 3340350d6..9d545a80c 100644 --- a/core/src/test/java/com/google/bitcoin/core/FakeChannelSink.java +++ b/core/src/test/java/com/google/bitcoin/core/FakeChannelSink.java @@ -1,18 +1,19 @@ package com.google.bitcoin.core; -import static org.jboss.netty.channel.Channels.fireChannelConnected; - import org.jboss.netty.channel.*; +import static org.jboss.netty.channel.Channels.fireChannelConnected; + public class FakeChannelSink extends AbstractChannelSink { - public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) - throws Exception { + public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws Exception { if (e instanceof ChannelStateEvent) { ChannelStateEvent event = (ChannelStateEvent) e; - FakeChannel channel = - (FakeChannel) event.getChannel(); + FakeChannel channel = (FakeChannel) event.getChannel(); + boolean offered = channel.events.offer(event); + assert offered; + ChannelFuture future = event.getFuture(); ChannelState state = event.getState(); Object value = event.getValue(); @@ -42,8 +43,6 @@ public class FakeChannelSink extends AbstractChannelSink { future.setSuccess(); break; } - boolean offered = channel.events.offer(event); - assert offered; } else if (e instanceof MessageEvent) { MessageEvent event = (MessageEvent) e; FakeChannel channel = (FakeChannel) event.getChannel();