diff --git a/lib/puppet/forge/repository.rb b/lib/puppet/forge/repository.rb
index fd92b7d44..cacfdc6ea 100644
--- a/lib/puppet/forge/repository.rb
+++ b/lib/puppet/forge/repository.rb
@@ -1,102 +1,102 @@
 require 'net/http'
 require 'digest/sha1'
 require 'uri'
 
 module Puppet::Forge
   # = Repository
   #
   # This class is a file for accessing remote repositories with modules.
   class Repository
 
     attr_reader :uri, :cache
 
     # Instantiate a new repository instance rooted at the optional string
     # +url+, else an instance of the default Puppet modules repository.
     def initialize(url=Puppet[:module_repository])
       @uri = url.is_a?(::URI) ? url : ::URI.parse(url.sub(/^(?!https?:\/\/)/, 'http://'))
       @cache = Cache.new(self)
     end
 
     # Read HTTP proxy configurationm from Puppet's config file, or the
     # http_proxy environment variable.
     def http_proxy_env
       proxy_env = ENV["http_proxy"] || ENV["HTTP_PROXY"] || nil
       begin
         return URI.parse(proxy_env) if proxy_env
       rescue URI::InvalidURIError
         return nil
       end
       return nil
     end
 
     def http_proxy_host
       env = http_proxy_env
 
       if env and env.host then
         return env.host
       end
 
       if Puppet.settings[:http_proxy_host] == 'none'
         return nil
       end
 
       return Puppet.settings[:http_proxy_host]
     end
 
     def http_proxy_port
       env = http_proxy_env
 
       if env and env.port then
         return env.port
       end
 
       return Puppet.settings[:http_proxy_port]
     end
 
     # Return a Net::HTTPResponse read for this +request+.
     def make_http_request(request, options = {})
       if ! @uri.user.nil? && ! @uri.password.nil?
         request.basic_auth(@uri.user, @uri.password)
       end
       return read_response(request)
     end
 
     # Return a Net::HTTPResponse read from this HTTPRequest +request+.
     def read_response(request)
       begin
         Net::HTTP::Proxy(
             http_proxy_host,
             http_proxy_port
             ).start(@uri.host, @uri.port) do |http|
           http.request(request)
         end
       rescue Errno::ECONNREFUSED, SocketError
         msg = "Error: Could not connect to #{@uri}\n"
         msg << "  There was a network communications problem\n"
         msg << "    Check your network connection and try again\n"
-        $stderr << msg
+        Puppet.err msg
         exit(1)
       end
     end
 
     # Return the local file name containing the data downloaded from the
     # repository at +release+ (e.g. "myuser-mymodule").
     def retrieve(release)
       return cache.retrieve(@uri + release)
     end
 
     # Return the URI string for this repository.
     def to_s
       return @uri.to_s
     end
 
     # Return the cache key for this repository, this a hashed string based on
     # the URI.
     def cache_key
       return @cache_key ||= [
         @uri.to_s.gsub(/[^[:alnum:]]+/, '_').sub(/_$/, ''),
         Digest::SHA1.hexdigest(@uri.to_s)
       ].join('-')
     end
   end
 end