Package com.google.mockwebserver

Examples of com.google.mockwebserver.MockWebServer.shutdown()

94
95
96
97
98
99
100
101
102
103
104
         RecordedRequest manifest = server.takeRequest();
         assertEquals(manifest.getRequestLine(), "PUT /container/foo HTTP/1.1");
         assertEquals(manifest.getHeader("X-Auth-Token"), token);
         assertEquals(manifest.getHeader("Content-Length"), "0");

         server.shutdown();
      }
   }

   private static final Set<Module> modules = ImmutableSet.<Module> of(new ExecutorServiceModule(sameThreadExecutor(),
         sameThreadExecutor()));
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
      RecordedRequest request = server.takeRequest();
      assertEquals(request.getRequestLine(), "PUT /bucket/object HTTP/1.1");
      assertEquals(request.getHeaders(CONTENT_LENGTH), ImmutableList.of("0"));
      // will fail unless -Dsun.net.http.allowRestrictedHeaders=true is set
      assertEquals(request.getHeaders(EXPECT), ImmutableList.of("100-continue"));
      server.shutdown();
   }

   public void testDirectorySeparator() throws IOException, InterruptedException {
      MockWebServer server = new MockWebServer();
      server.enqueue(new MockResponse().setBody("").addHeader(ETAG, "ABCDEF"));
View Full Code Here
103
104
105
106
107
108
109
110
      RecordedRequest request = server.takeRequest();
      assertEquals(request.getRequestLine(), "PUT /bucket/someDir/fileName HTTP/1.1");
      // will fail unless -Dsun.net.http.allowRestrictedHeaders=true is set
      assertEquals(request.getHeaders(EXPECT), ImmutableList.of("100-continue"));

      server.shutdown();
   }
}
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
         assertEquals(manifest.getHeader("Content-Length"), "161");
         assertEquals(
               new String(manifest.getBody()),
               "<CompleteMultipartUpload><Part><PartNumber>1</PartNumber><ETag>a00</ETag></Part><Part><PartNumber>2</PartNumber><ETag>b00</ETag></Part></CompleteMultipartUpload>");

         server.shutdown();
      }
   }

   @Test(expectedExceptions = HttpResponseException.class)
   public void testMPUAbortsOnProblem() throws IOException, InterruptedException {
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
         assertEquals(new String(part1.getBody()), "01234567");

         RecordedRequest abort = server.takeRequest();
         assertEquals(abort.getRequestLine(), "DELETE /container/foo?uploadId=upload-id HTTP/1.1");

         server.shutdown();
      }
   }

   private static final Set<Module> modules = ImmutableSet.<Module> of(new ExecutorServiceModule(sameThreadExecutor(),
         sameThreadExecutor()));
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
         RecordedRequest login = server.takeRequest();
         assertEquals(login.getRequestLine(), "POST /v0.8/login HTTP/1.1");
         assertEquals(login.getHeader("Authorization"), "Basic dXNlcjpwYXNzd29yZA==");
         assertEquals(login.getHeader("Content-Length"), "0");

         server.shutdown();
      }
   }

   /**
    * there's no built-in way to defer evaluation of a response header, hence this
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
         RecordedRequest manifest = server.takeRequest();
         assertEquals(manifest.getRequestLine(), "PUT /container/foo HTTP/1.1");
         assertEquals(manifest.getHeader("X-Auth-Token"), token);
         assertEquals(manifest.getHeader("Content-Length"), "0");

         server.shutdown();
      }
   }

   private static final Set<Module> modules = ImmutableSet.<Module> of(new ExecutorServiceModule(sameThreadExecutor(),
         sameThreadExecutor()));
View Full Code Here
79
80
81
82
83
84
85
86
87
         assertEquals(server.getRequestCount(), 1);
         RecordedRequest authRequest = server.takeRequest();
         assertEquals(authRequest.getRequestLine(), "POST /tokens HTTP/1.1");
      } finally {
         server.shutdown();
      }
   }
}
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
      DynECTApi api = mockDynectApi(server.getUrl("/").toString());

      try {
         api.getZoneApi().list();
      } finally {
         server.shutdown();
      }
   }

   String taskBlocking = "[{\"status\": \"failure\", \"data\": {}, \"job_id\": 275545493, \"msgs\": [{\"INFO\": \"zone: Operation blocked by current task\", \"SOURCE\": \"BLL\", \"ERR_CD\": \"ILLEGAL_OPERATION\", \"LVL\": \"ERROR\"}, {\"INFO\": \"task_name: ProvisionZone\", \"SOURCE\": \"BLL\", \"ERR_CD\": null, \"LVL\": \"INFO\"}, {\"INFO\": \"task_id: 39120953\", \"SOURCE\": \"BLL\", \"ERR_CD\": null, \"LVL\": \"INFO\"}]}]";
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
      DynECTApi api = mockDynectApi(server.getUrl("/").toString());

      try {
         api.getZoneApi().list();
      } finally {
         server.shutdown();
      }
   }

   String targetExists = "[{\"status\": \"failure\", \"data\": {}, \"job_id\": 275533917, \"msgs\": [{\"INFO\": \"name: Name already exists\", \"SOURCE\": \"BLL\", \"ERR_CD\": \"TARGET_EXISTS\", \"LVL\": \"ERROR\"}, {\"INFO\": \"create: You already have this zone.\", \"SOURCE\": \"BLL\", \"ERR_CD\": null, \"LVL\": \"INFO\"}]}]";
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.