final DfsReferral start = dr;
            SmbException se = null;

            do {
                try {
                    if (LogStream.level >= 2) {
                        log.println("DFS redirect: " + dr);
                    }

                    final UniAddress addr = UniAddress.getByName(dr.server);
                    final SmbTransport trans = SmbTransport.getSmbTransport(addr, url.getPort());

   * Map<String, Integer> map = ImmutableMap.of("a", 4, "b", 9);
   * Function<Integer, Double> sqrt = (Integer in) -> Math.sqrt((int) in);
   * Map<String, Double> transformed = Maps.transformValues(map, sqrt);
   * System.out.println(transformed);
   * }
   *
   * ... prints {@code {a=2.0, b=3.0}}.
   *
   * <p>Changes in the underlying map are reflected in this view. Conversely, this view supports

   * Map<String, Integer> map = ImmutableMap.of("a", 4, "b", 9);
   * Function<Integer, Double> sqrt = (Integer in) -> Math.sqrt((int) in);
   * Map<String, Double> transformed = Maps.transformValues(map, sqrt);
   * System.out.println(transformed);
   * }
   *
   * ... prints {@code {a=2.0, b=3.0}}.
   *
   * <p>Changes in the underlying map are reflected in this view. Conversely, this view supports

		req.Header.Set(k, v[0])
	}

	// execute the request.
	response, err = s.client.Do(req)
	c.Assert(err, nil)

	// out, err = httputil.DumpResponse(response, true)
	// fmt.Println("RESPONSE ===\n", string(out), err)

	// assert the http response status code.
	c.Assert(response.StatusCode, http.StatusBadRequest)
}

func (s *TestSuiteCommon) TestBucketSQSNotificationAMQP(c *check) {