Changed pendingWrites to have type Map<InetAddress, BlockingQueue<ByteBuffer>>. Having a SocketChannel as a key could lead to bad things if that socket channel had since been replaced by a new connection to the same node. Similarly, changed the ChangeRequest class to not keep a reference to the socket channel.