Package com.google.mockwebserver

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

106
107
108
109
110
111
112
113
114
      DynECTApi api = mockDynectApi(server.getUrl("/").toString());

      try {
         api.getZoneApi().list();
      } finally {
         server.shutdown();
      }
   }
}
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
      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
101
102
103
104
105
106
107
108
      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
91
92
93
94
95
96
97
98
99
100
101
         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
125
126
127
128
129
130
131
132
133
134
135
         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
77
78
79
80
81
82
83
84
85
86
87
      assertEquals(server2.getRequestCount(), 1);
      // TODO: verify ribbon stats match
      // assertEquals(target.lb().getLoadBalancerStats().getSingleServerStat())
    } finally {
      server1.shutdown();
      server2.shutdown();
      getConfigInstance().clearProperty(serverListKey);
    }
  }

  @Test
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
      assertEquals(server.getRequestCount(), 2);
      // TODO: verify ribbon stats match
      // assertEquals(target.lb().getLoadBalancerStats().getSingleServerStat())
    } finally {
      server.shutdown();
      getConfigInstance().clearProperty(serverListKey);
    }
  }

  /*
 
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
      final String recordedRequestLine = server.takeRequest().getRequestLine();

      assertEquals(recordedRequestLine, expectedRequestLine);
    } finally {
      server.shutdown();
      getConfigInstance().clearProperty(serverListKey);
    }
  }

View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
      assertEquals(server2.getRequestCount(), 1);
      // TODO: verify ribbon stats match
      // assertEquals(target.lb().getLoadBalancerStats().getSingleServerStat())
    } finally {
      server1.shutdown();
      server2.shutdown();
      getConfigInstance().clearProperty(serverListKey);
    }
  }

  static String hostAndPort(URL url) {
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
         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
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.