Fix issue #211 - ServerInfo.ping

This commit is contained in:
md_5 2013-03-19 11:40:56 +11:00
parent a12debf6d0
commit 49f2f5f28b

View File

@ -59,12 +59,14 @@ public class BungeeServerInfo extends ServerInfo
@Override @Override
public void operationComplete(ChannelFuture future) throws Exception public void operationComplete(ChannelFuture future) throws Exception
{ {
if ( !future.isSuccess() ) if ( future.isSuccess() )
{
future.channel().pipeline().get( HandlerBoss.class ).setHandler( new PingHandler( BungeeServerInfo.this, callback ) );
} else
{ {
callback.done( null, future.cause() ); callback.done( null, future.cause() );
} }
} }
} ) } );
.channel().pipeline().get( HandlerBoss.class ).setHandler( new PingHandler( this, callback ) );
} }
} }