Package com.google.appengine.api.urlfetch

Examples of com.google.appengine.api.urlfetch.HTTPRequest.addHeader()

88
89
90
91
92
93
94
95
96
97
98
      for (Entry<String, String> entry : request.getHeaders().entries()) {
         String header = entry.getKey();
         if (!prohibitedHeaders.contains(header))
            gaeRequest.addHeader(new HTTPHeader(header, entry.getValue()));
      }
      gaeRequest.addHeader(new HTTPHeader(HttpHeaders.USER_AGENT, USER_AGENT));
      /**
       * byte [] content is replayable and the only content type supportable by GAE. As such, we
       * convert the original request content to a byte array.
       */
      if (request.getPayload() != null) {
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
  @Override
  public List<GcsBucket> listBuckets() throws GcsException {
    try {
      HTTPRequest request = ExtendedOauthRawGcsService.makeGetRequest();
      request.addHeader(new HTTPHeader("Accept-Encoding", "identity"));
      HTTPResponse response = ExtendedOauthRawGcsService.doRequest(request, urlFetchService);
      System.out.println("new String(response.getContent()) = " + new String(response.getContent()));
      DocumentBuilder builder = DocumentBuilderFactory.newInstance().newDocumentBuilder();
      Document document = builder.parse(new ByteArrayInputStream(response.getContent()));
      return Parser.parseBucketList(document);
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
  }

  static HTTPRequest copyRequest(HTTPRequest in) {
    HTTPRequest out = new HTTPRequest(in.getURL(), in.getMethod(), in.getFetchOptions());
    for (HTTPHeader h : in.getHeaders()) {
      out.addHeader(h);
    }
    out.setPayload(in.getPayload());
    return out;
  }
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
        // add the headers to the request
        if (options.containsKey("headers")) {
            @SuppressWarnings("unchecked") Map<String, String> headers = (Map<String, String>) options.get("headers");
            for (Entry<String, String> e : headers.entrySet()) {
                request.addHeader(new HTTPHeader(e.getKey(), e.getValue()));
            }
        }

        // add the payload
        if (options.containsKey("payload")) {
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
public class HttpRequestTest extends URLFetchTestBase {

    @Test
    public void testGetters() throws Exception {
        HTTPRequest request = new HTTPRequest(getFetchUrl(), HTTPMethod.PATCH, FetchOptions.Builder.withDefaults());
        request.addHeader(new HTTPHeader("foo", "bar"));
        request.setPayload("qwerty".getBytes());

        Assert.assertEquals(getFetchUrl(), request.getURL());
        Assert.assertEquals(HTTPMethod.PATCH, request.getMethod());
        Assert.assertNotNull(request.getFetchOptions());
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
      HTTPRequest gaeRequest = new HTTPRequest(url, HTTPMethod.valueOf(request.getMethod().toString()), options);

      for (Entry<String, String> entry : request.getHeaders().entries()) {
         String header = entry.getKey();
         if (!prohibitedHeaders.contains(header))
            gaeRequest.addHeader(new HTTPHeader(header, entry.getValue()));
      }
      gaeRequest.addHeader(new HTTPHeader(HttpHeaders.USER_AGENT, USER_AGENT));
      /**
       * byte [] content is replayable and the only content type supportable by GAE. As such, we
       * convert the original request content to a byte array.
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
      for (Entry<String, String> entry : request.getHeaders().entries()) {
         String header = entry.getKey();
         if (!prohibitedHeaders.contains(header))
            gaeRequest.addHeader(new HTTPHeader(header, entry.getValue()));
      }
      gaeRequest.addHeader(new HTTPHeader(HttpHeaders.USER_AGENT, USER_AGENT));
      /**
       * byte [] content is replayable and the only content type supportable by GAE. As such, we
       * convert the original request content to a byte array.
       */
      if (request.getPayload() != null) {
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
      HTTPRequest gaeRequest = new HTTPRequest(url, HTTPMethod.valueOf(request.getMethod().toString()), options);

      for (Entry<String, String> entry : request.getHeaders().entries()) {
         String header = entry.getKey();
         if (!prohibitedHeaders.contains(header))
            gaeRequest.addHeader(new HTTPHeader(header, entry.getValue()));
      }
      gaeRequest.addHeader(new HTTPHeader(HttpHeaders.USER_AGENT, USER_AGENT));
      /**
       * byte [] content is replayable and the only content type supportable by GAE. As such, we
       * convert the original request content to a byte array.
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
      for (Entry<String, String> entry : request.getHeaders().entries()) {
         String header = entry.getKey();
         if (!prohibitedHeaders.contains(header))
            gaeRequest.addHeader(new HTTPHeader(header, entry.getValue()));
      }
      gaeRequest.addHeader(new HTTPHeader(HttpHeaders.USER_AGENT, USER_AGENT));
      /**
       * byte [] content is replayable and the only content type supportable by GAE. As such, we
       * convert the original request content to a byte array.
       */
      if (request.getPayload() != null) {
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
  @Inject Metrics metrics;

  public void send(String from, String to, String body, String inReplyTo, String references) {
    try {
      HTTPRequest request = new HTTPRequest(new URL(SENDGRID_SEND_URL), HTTPMethod.POST);
      request.addHeader(new HTTPHeader(CONTENT_TYPE, FORM_UTF8_MIME));
      request.setPayload(encodeQuery(new ImmutableMap.Builder<String, String>()
          .put("api_user", apiUser)
          .put("api_key", apiKey)
          .put("to", to)
          .put("from", from)
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.