Fixed NPE on interruption

This commit is contained in:
Trustin Lee 2009-04-15 07:41:25 +00:00
parent bd1d184d69
commit 40c4d84477

View File

@ -72,9 +72,9 @@ final class HttpTunnelWorker implements Runnable {
break;
}
ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(buf);
fireMessageReceived(channel, buffer);
if (buf != null) {
fireMessageReceived(channel, ChannelBuffers.wrappedBuffer(buf));
}
}
// Setting the workerThread to null will prevent any channel