• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Times类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.mockserver.matchers.Times的典型用法代码示例。如果您正苦于以下问题:Java Times类的具体用法?Java Times怎么用?Java Times使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Times类属于org.mockserver.matchers包,在下文中一共展示了Times类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: startServer

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void startServer() {
  mockServer = ClientAndServer.startClientAndServer(7755);

  MockServerClient client = new MockServerClient("localhost", 7755)
    .reset();

  client.when(HttpRequest.request()
        .withMethod("PUT")
        .withPath("/v0.3/traces")
        .withHeaders(new Header("Content-Type", "application/msgpack")),
        Times.exactly(1), TimeToLive.exactly(TimeUnit.MINUTES, 1l))
    .respond(HttpResponse.response()
        .withStatusCode(200)
        .withHeaders(new Header("Content-Type", "text/plain"))
        .withBody("OK\n")
    );
}
 
开发者ID:chonton,项目名称:apm-client,代码行数:18,代码来源:WriterBackoffTest.java


示例2: emulateV0_2

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Before
public void emulateV0_2() {
  MockServerClient client = new MockServerClient("localhost", APM_PORT).reset();

  client.when(
      HttpRequest.request()
          .withMethod("PUT")
          .withPath("/v0.3/traces"), Times.unlimited(), TimeToLive.exactly(TimeUnit.MINUTES, 1l))
      .respond(HttpResponse.response()
          .withStatusCode(404)
          .withHeaders(new Header("Content-Type", "text/plain")));

  client.when(
      HttpRequest.request()
          .withMethod("PUT")
          .withPath("/v0.2/traces"), Times.unlimited(), TimeToLive.exactly(TimeUnit.MINUTES, 1l))
      .respond(HttpResponse.response()
          .withStatusCode(200)
          .withHeaders(new Header("Content-Type", "text/plain"))
          .withBody("OK\n").withDelay(new Delay(TimeUnit.MILLISECONDS, 20)));
}
 
开发者ID:chonton,项目名称:apm-client,代码行数:22,代码来源:HelloIT.java


示例3: emulateV0_2

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Before
public void emulateV0_2() {
  MockServerClient client = new MockServerClient("localhost", APM_PORT)
    .reset();

  client
    .when(HttpRequest.request().withMethod("PUT").withPath("/v0.3/traces"),
        Times.unlimited(), TimeToLive.exactly(TimeUnit.MINUTES, 1l))
    .respond(HttpResponse.response().withStatusCode(404)
      .withHeaders(new Header("Content-Type", "text/plain"))
  );

  client
    .when(HttpRequest.request().withMethod("PUT").withPath("/v0.2/traces"),
      Times.unlimited(), TimeToLive.exactly(TimeUnit.MINUTES, 1l))
    .respond(HttpResponse.response().withStatusCode(200)
      .withHeaders(new Header("Content-Type", "text/plain")).withBody("OK\n")
      .withDelay(new Delay(TimeUnit.MILLISECONDS, 20)));
}
 
开发者ID:chonton,项目名称:apm-client,代码行数:20,代码来源:HelloIT.java


示例4: emailUser

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void emailUser(MockServerClient mockServerClient) {

        mockServerClient.
        dumpToLog().
        when(
            HttpRequest.request()
            .withMethod("POST")
            .withCookie(Cookie.cookie("session", "0a1bc2a7-11ef-4781-9c06-8d9b42719797"))
            .withCookie(Cookie.cookie("username", "jdoe"))
            .withPath("/user/email")
            .withBody("{\"name\":\"John Doe\"}"),
            Times.unlimited()
        ).respond(
            HttpResponse.response()
            .withStatusCode(200)
            
        );        
    }
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:19,代码来源:MockServerInitializationClass.java


示例5: mutateUser

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void mutateUser(MockServerClient mockServerClient) {

    mockServerClient.
    dumpToLog().
    when(
        HttpRequest.request()
        .withMethod("PUT")
        .withCookie(Cookie.cookie("session", "aa8a2e85-412e-46a2-889f-b2c133a59c89"))
        .withPath("/user")
        .withBody("{\"name\":\"John Doe\"}"),
        Times.unlimited()
    ).respond(
        HttpResponse.response()
        .withStatusCode(200)
        
    );        
}
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:18,代码来源:MockServerInitializationClass.java


示例6: getUsers

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void getUsers(MockServerClient mockServerClient) {

        mockServerClient
        .dumpToLog()
        .when(
            HttpRequest.request()
            .withMethod("GET")
            .withPath("/user")
            .withHeader(Header.header("X-SESSION-ID", "020835c7-cf7e-4ba5-b117-4402e5d79079"))
            .withQueryStringParameter(Parameter.param("byUsername", "jdoe")),
            Times.unlimited()
        ).respond(
            HttpResponse.response()
            .withStatusCode(200)
            .withBody("{ \"users\" : [{ \"name\" : \"John Doe\" }] }")
        );
    }
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:18,代码来源:MockServerInitializationClass.java


示例7: getUser

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void getUser(MockServerClient mockServerClient) {

        mockServerClient
        .dumpToLog()
        .when(
            HttpRequest.request()
            .withMethod("GET")
            .withHeader(Header.header("X-SESSION-ID", "55892d6d-77df-4617-b728-6f5de97f5752"))
            .withPath("/user/jdoe"),
            Times.unlimited()
        ).respond(
            HttpResponse.response()
            .withStatusCode(200)
            .withBody("{ \"name\" : \"John Doe\" }")
        );
    }
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:17,代码来源:MockServerInitializationClass.java


示例8: getCachedUser

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void getCachedUser(MockServerClient mockServerClient) {

        mockServerClient
        .dumpToLog()
        .when(
            HttpRequest.request()
            .withMethod("GET")
            .withHeader(Header.header("X-SESSION-ID", "55892d6d-77df-4617-b728-6f5de97f5752"))
            .withPath("/user/bdoe"),
            Times.unlimited()
        ).respond(
            HttpResponse.response()
            .withStatusCode(200)
            .withHeader(Header.header("Cache-Control","no-transform,public,max-age=300,s-maxage=900"))
            .withBody("{ \"name\" : \"Bob Doe\" }")
        );
    }
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:18,代码来源:MockServerInitializationClass.java


示例9: getUserAddress

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void getUserAddress(MockServerClient mockServerClient) {

        mockServerClient
        .dumpToLog()
        .when(
            HttpRequest.request()
            .withMethod("GET")
            .withHeader(Header.header("Cache-Control", "no-cache"))
            .withPath("/user/address/jdoe"),
            Times.unlimited()
        ).respond(
            HttpResponse.response()
            .withStatusCode(200)
            .withBody("{ \"address\" : \"1060 W Addison St, Chicago, IL 60613\" }")
        );
    }
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:17,代码来源:MockServerInitializationClass.java


示例10: getRoleUsers

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void getRoleUsers(MockServerClient mockServerClient) {

    mockServerClient
    .dumpToLog()
    .when(
        HttpRequest.request()
        .withMethod("GET")
        .withPath("/user/role")
        .withQueryStringParameter(Parameter.param("byRole", "vanessa")),
        Times.unlimited()
    ).respond(
        HttpResponse.response()
        .withStatusCode(200)
        .withBody("{ \"users\" : [] }")
    );
}
 
开发者ID:kenzanlabs,项目名称:bowtie,代码行数:17,代码来源:MockServerInitializationClass.java


示例11: testEnableAuth

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
public void testEnableAuth() throws Exception {
  VaultConfiguration conf = VaultConfigurationBuilder.newVaultConfiguration()
      .withAddress(address)
      .withToken(token)
      .build();

  new MockServerClient(localhost, mockServerRule.getPort())
      .when(
      HttpRequest.request()
          .withMethod("POST")
          .withHeader(tokenHeader)
          .withPath("/v1/sys/auth/app-id")
          .withBody("{\"type\":\"app-id\"}"),
      Times.exactly(1)
  )
  .respond(
      HttpResponse.response()
          .withStatusCode(HttpStatusCode.NO_CONTENT_204.code())
          .withHeader(contentJson)
  );

  VaultClient vault = new VaultClient(conf);
  assertTrue(vault.sys().auth().enable("app-id", "app-id"));
}
 
开发者ID:streamsets,项目名称:datacollector,代码行数:26,代码来源:TestAuth.java


示例12: startServer

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Before
public void startServer() {
  mockServer = ClientAndServer.startClientAndServer(7755);

  new MockServerClient("localhost", 7755)
      .when(HttpRequest.request().withMethod("PUT"), 
          Times.exactly(1),
          TimeToLive.exactly(TimeUnit.MINUTES, 1l))
      .respond(HttpResponse.response().withStatusCode(200)
          .withHeaders(new Header("Content-Type", "text/plain")).withBody("OK\n")
          .withDelay(new Delay(TimeUnit.SECONDS, 1)));
}
 
开发者ID:chonton,项目名称:apm-client,代码行数:13,代码来源:ApmApiTest.java


示例13: expectations

import org.mockserver.matchers.Times; //导入依赖的package包/类
private void expectations(int status) {
  MockServerClient client = new MockServerClient("localhost", 7755)
    .reset();

  client.when(HttpRequest.request()
        .withMethod("PUT")
        .withPath("/v0.3/traces")
        .withHeaders(new Header("Content-Type", "application/msgpack")),
        Times.exactly(1), TimeToLive.exactly(TimeUnit.MINUTES, 1l))
    .respond(HttpResponse.response()
        .withStatusCode(status)
        .withHeaders(new Header("Content-Type", "text/plain"))
    );
  client.when(HttpRequest.request()
        .withMethod("PUT")
        .withPath("/v0.2/traces")
        .withHeaders(new Header("Content-Type", "application/json")),
        Times.exactly(1),
        TimeToLive.exactly(TimeUnit.MINUTES, 1l))
    .respond(HttpResponse.response()
        .withStatusCode(200)
        .withHeaders(new Header("Content-Type", "text/plain"))
        .withBody("OK\n")
    );
}
 
开发者ID:chonton,项目名称:apm-client,代码行数:26,代码来源:WriterTest.java


示例14: mailShouldStillBeDeliveredWhenClassificationFails

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
public void mailShouldStillBeDeliveredWhenClassificationFails() throws Exception {
    String recipientTo = "[email protected]" + DEFAULT_DOMAIN;
    String response = "{}";
    mockServerClient
        .when(HttpRequest.request()
                .withMethod("POST")
                .withPath("/email/classification/predict")
                .withQueryStringParameter(new Parameter("recipients", "[email protected]")),
            Times.exactly(1))
        .respond(HttpResponse.response(response));

    DataProbe dataProbe = jamesServer.getProbe(DataProbeImpl.class);
    dataProbe.addDomain(DEFAULT_DOMAIN);
    String from = "[email protected]" + DEFAULT_DOMAIN;
    dataProbe.addUser(from, PASSWORD);
    dataProbe.addUser(recipientTo, PASSWORD);
    jamesServer.getProbe(MailboxProbeImpl.class).createMailbox(MailboxConstants.USER_NAMESPACE, recipientTo, "INBOX");

    try (SMTPMessageSender messageSender = SMTPMessageSender.noAuthentication(LOCALHOST_IP, SMTP_PORT, DEFAULT_DOMAIN);
         IMAPMessageReader imapMessageReader = new IMAPMessageReader(LOCALHOST_IP, IMAP_PORT)) {
        messageSender.sendMessage(from, recipientTo);
        calmlyAwait.until(messageSender::messageHasBeenSent);
        calmlyAwait.until(() -> imapMessageReader.userReceivedMessage(recipientTo, PASSWORD));
    }
}
 
开发者ID:linagora,项目名称:openpaas-mailets,代码行数:27,代码来源:ClassificationIntegrationTest.java


示例15: testReadwith404Uri

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
  public void testReadwith404Uri() throws Exception {
    String path = "/rsserv/capabilitylist.xml";
    URI uri = composeUri(path);

    getMockServer()
      .when(HttpRequest.request()
          .withMethod("GET")
          .withPath(path),
        Times.exactly(1))

      .respond(HttpResponse.response()
        .withStatusCode(404)
        .withHeader("Content-Type", "text/plain; utf-8")
        .withBody("Not Found")
      );

    RsDocumentReader reader = new RsDocumentReader(getHttpclient(), getRsContext());
    Result<RsRoot> result = reader.read(uri);
    assertThat(result.getErrors().isEmpty(), is(false));
    assertThat(result.getStatusCode(), is(404));

    assertThat(reader.getLatestUrlset().isPresent(), is(false));
    assertThat(reader.getLatestSitemapindex().isPresent(), is(false));
//    System.out.println(result);
  }
 
开发者ID:EHRI,项目名称:rs-aggregator,代码行数:27,代码来源:RsDocumentReaderTest.java


示例16: testReadNoContent

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
public void testReadNoContent() throws Exception {
  String path = "/rsserv/nothing";
  URI uri = composeUri(path);

  getMockServer()
    .when(HttpRequest.request()
        .withMethod("GET")
        .withPath(path),
      Times.exactly(1))

    .respond(HttpResponse.response()
      .withStatusCode(204)
    );

  RsDocumentReader reader = new RsDocumentReader(getHttpclient(), getRsContext());
  Result<RsRoot> result = reader.read(uri);

  assertThat(result.getContent().isPresent(), is(false));
  assertThat(result.getStatusCode(), is(204));
  assertThat(result.getErrors().size(), is(0));
}
 
开发者ID:EHRI,项目名称:rs-aggregator,代码行数:23,代码来源:RsDocumentReaderTest.java


示例17: testReadAnd404

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
public void testReadAnd404() throws Exception {
  String path = "/rsserv/nice.txt";
  URI uri = composeUri(path);

  getMockServer()
    .when(HttpRequest.request()
        .withMethod("GET")
        .withPath(path),
      Times.exactly(1))

    .respond(HttpResponse.response()
      .withStatusCode(404)
      .withHeader("Content-Type", "text/plain; utf-8")
      .withBody("Not Found")
    );

  ResourceReader rsReader = new ResourceReader(getHttpclient());
  File file = new File("target/test-output/rsreader/not_found.txt");
  Result<File> result = rsReader.read(uri, file);

  assertThat(result.getErrors().isEmpty(), is(false));
  assertThat(result.getStatusCode(), is(404));
  assertThat(result.getContent().isPresent(), is(false));
  assertThat(result.getErrors().get(0), instanceOf(RemoteException.class));
}
 
开发者ID:EHRI,项目名称:rs-aggregator,代码行数:27,代码来源:ResourceReaderTest.java


示例18: testReadAndNoContent

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
public void testReadAndNoContent() throws Exception {
  String path = "/rsserv/nice.txt";
  URI uri = composeUri(path);

  getMockServer()
    .when(HttpRequest.request()
        .withMethod("GET")
        .withPath(path),
      Times.exactly(1))

    .respond(HttpResponse.response()
      .withStatusCode(204)
    );

  ResourceReader rsReader = new ResourceReader(getHttpclient());
  File file = new File("target/test-output/rsreader/no_content.txt");
  Result<File> result = rsReader.read(uri, file);

  assertThat(result.getErrors().isEmpty(), is(true));
  assertThat(result.getStatusCode(), is(204));
  assertThat(result.getContent().isPresent(), is(false));
}
 
开发者ID:EHRI,项目名称:rs-aggregator,代码行数:24,代码来源:ResourceReaderTest.java


示例19: receiveStatusError

import org.mockserver.matchers.Times; //导入依赖的package包/类
@Test
public void receiveStatusError() throws Exception {
  String path = "/.well-known/resourcesync";

  getMockServer()
    .when(HttpRequest.request()
        .withMethod("GET")
        .withPath(path),
      Times.exactly(1))

    .respond(HttpResponse.response()
      .withStatusCode(404)
      .withBody("Document not found")
    );

  RsExplorer explorer = new RsExplorer(getHttpclient(), getRsContext());
  ResultIndex index = new ResultIndex();
  Result<RsRoot> result = explorer.explore(composeUri(path), index);

  assertThat(result.getUri(), equalTo(composeUri(path)));
  assertThat(result.getStatusCode(), equalTo(404));
  assertThat(result.getErrors().isEmpty(), is(false));
  assertThat(result.getErrors().get(0), instanceOf(RemoteException.class));
  assertThat(result.getContent().isPresent(), is(false));
  //result.listErrors().forEach(Throwable::printStackTrace);
}
 
开发者ID:EHRI,项目名称:rs-aggregator,代码行数:27,代码来源:RsExplorerTest.java


示例20: testNullHttpFilterSource

import org.mockserver.matchers.Times; //导入依赖的package包/类
/**
 * Verifies that the proxy properly handles a null HttpFilters instance, as allowed in the
 * {@link HttpFiltersSource#filterRequest(HttpRequest, ChannelHandlerContext)} documentation.
 */
@Test
public void testNullHttpFilterSource() throws Exception {
    mockServer.when(request()
                    .withMethod("GET")
                    .withPath("/testNullHttpFilterSource"),
            Times.exactly(1))
            .respond(response()
                    .withStatusCode(200)
                    .withBody("success"));

    HttpFiltersSource filtersSource = new HttpFiltersSourceAdapter() {
        @Override
        public HttpFilters filterRequest(HttpRequest originalRequest) {
            return null;
        }
    };

    setUpHttpProxyServer(filtersSource);

    org.apache.http.HttpResponse httpResponse = HttpClientUtil.performHttpGet("http://localhost:" + mockServerPort + "/testNullHttpFilterSource", proxyServer);
    Thread.sleep(500);

    assertEquals("Expected to receive an HTTP 200 from proxy", 200, httpResponse.getStatusLine().getStatusCode());
}
 
开发者ID:wxyzZ,项目名称:little_mitm,代码行数:29,代码来源:HttpFilterTest.java



注:本文中的org.mockserver.matchers.Times类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ImeAdapter类代码示例发布时间:2022-05-22
下一篇:
Java AmazonSimpleEmailService类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap