# File gofer/messaging/broker.rb, line 49
  def connect()
    if @connection.nil?
      s = TCPSocket.new(@url.host(), @url.port())
      @connection = Qpid::Connection.new(s)
      @connection.start(10)
    end
    return @connection
  end