org.easymock.EasyMock.anyString()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(178)

本文整理了Java中org.easymock.EasyMock.anyString()方法的一些代码示例，展示了EasyMock.anyString()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。EasyMock.anyString()方法的具体详情如下：
包路径：org.easymock.EasyMock
类名称：EasyMock
方法名：anyString

EasyMock.anyString介绍

[英]Expect any string whatever its content is. Exactly the same as #anyObject() but prevents typing issues for the much used String type. Consider this method to be a syntactic sugar.
[中]期望任何字符串，无论其内容是什么。与#anyObject（）完全相同，但防止了常用字符串类型的键入问题。认为这个方法是句法糖。

代码示例

代码示例来源：origin: confluentinc/ksql

  1. private void givenPredicateWillReturnTrue() {
  2.   EasyMock.reset(cliLinePredicate);
  3.   EasyMock.expect(cliLinePredicate.test(anyString())).andReturn(true);
  4.   EasyMock.replay(cliLinePredicate);
  5.  }
  6. }

代码示例来源：origin: confluentinc/ksql

  1. @Before
  2. public void setUp() {
  3.  EasyMock.expect(cliLinePredicate.test(anyString())).andReturn(false);
  4.  EasyMock.replay(cliLinePredicate);
  5.  parser = new KsqlLineParser(delegate, cliLinePredicate);
  6. }

代码示例来源：origin: apache/incubator-druid

  1. @Test
  2. public void testShutdownAllTasksForNonExistingDataSource()
  3. {
  4.  final TaskQueue taskQueue = EasyMock.createMock(TaskQueue.class);
  5.  EasyMock.expect(taskMaster.isLeader()).andReturn(true).anyTimes();
  6.  EasyMock.expect(taskMaster.getTaskQueue()).andReturn(Optional.of(taskQueue)).anyTimes();
  7.  EasyMock.expect(taskStorageQueryAdapter.getActiveTaskInfo(EasyMock.anyString())).andReturn(Collections.emptyList());
  8.  EasyMock.replay(taskRunner, taskMaster, taskStorageQueryAdapter, indexerMetadataStorageAdapter, req);
  9.  final Response response = overlordResource.shutdownTasksForDataSource("notExisting");
  10.  Assert.assertEquals(Status.NOT_FOUND.getStatusCode(), response.getStatus());
  11. }

代码示例来源：origin: apache/incubator-druid

  1. private ImmutableWorkerInfo createMockWorker(int currCapacityUsed, boolean canRunTask, boolean isValidVersion)
  2. {
  3.  ImmutableWorkerInfo worker = EasyMock.createMock(ImmutableWorkerInfo.class);
  4.  EasyMock.expect(worker.canRunTask(EasyMock.anyObject(Task.class))).andReturn(canRunTask).anyTimes();
  5.  EasyMock.expect(worker.getCurrCapacityUsed()).andReturn(currCapacityUsed).anyTimes();
  6.  EasyMock.expect(worker.isValidVersion(EasyMock.anyString())).andReturn(isValidVersion).anyTimes();
  7.  EasyMock.replay(worker);
  8.  return worker;
  9. }

代码示例来源：origin: apache/incubator-druid

  1. @Before
  2. public void setUp()
  3. {
  4.  EasyMock.expect(lookupReferencesManager.get("lookupId")).andReturn(
  5.    new LookupExtractorFactoryContainer(
  6.      "v0",
  7.      lookupExtractorFactory
  8.    )
  9.  ).anyTimes();
  10.  EasyMock.expect(lookupReferencesManager.get(EasyMock.anyString())).andReturn(null).anyTimes();
  11.  EasyMock.replay(lookupReferencesManager);
  12. }
  13. @Test

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void shouldPrintServerAddressWhenEmptyStringArg() throws Exception {
  3.  expect(restClient.makeRootRequest()).andReturn(RestResponse.successful(SERVER_INFO));
  4.  expect(restClient.getServerAddress()).andReturn(new URI(INITIAL_SERVER_ADDRESS));
  5.  restClient.setServerAddress(anyString());
  6.  expectLastCall().andThrow(new AssertionError("should not set address"));
  7.  replay(restClient);
  8.  command.execute(ImmutableList.of(), terminal);
  9.  assertThat(out.toString(), equalTo(INITIAL_SERVER_ADDRESS + "\n"));
  10. }

代码示例来源：origin: apache/incubator-druid

  1. @Test
  2. public void testServiceAnnouncementDELETEExceptionInHandler()
  3. {
  4.  final ListenerHandler handler = EasyMock.createStrictMock(ListenerHandler.class);
  5.  EasyMock.expect(handler.handleDELETE(EasyMock.anyString())).andThrow(new RuntimeException("test"));
  6.  final ListenerResource resource = new ListenerResource(
  7.    mapper,
  8.    mapper,
  9.    handler
  10.  )
  11.  {
  12.  };
  13.  EasyMock.replay(handler);
  14.  Assert.assertEquals(
  15.    Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(),
  16.    resource.serviceAnnouncementDELETE("id").getStatus()
  17.  );
  18.  EasyMock.verify(handler);
  19. }

代码示例来源：origin: apache/incubator-druid

  1. @Test
  2. public void testServiceAnnouncementGETExceptionInHandler()
  3. {
  4.  final ListenerHandler handler = EasyMock.createStrictMock(ListenerHandler.class);
  5.  EasyMock.expect(handler.handleGET(EasyMock.anyString())).andThrow(new RuntimeException("test"));
  6.  final ListenerResource resource = new ListenerResource(
  7.    mapper,
  8.    mapper,
  9.    handler
  10.  )
  11.  {
  12.  };
  13.  EasyMock.replay(handler);
  14.  Assert.assertEquals(
  15.    Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(),
  16.    resource.serviceAnnouncementGET("id").getStatus()
  17.  );
  18.  EasyMock.verify(handler);
  19. }

代码示例来源：origin: confluentinc/ksql

  1. @Before
  2. public void setUp() {
  3.  propsWithMockParser = new LocalProperties(INITIAL, parser);
  4.  expect(parser.parse(anyString(), anyObject()))
  5.    .andReturn("parsed-val");
  6.  replay(parser);
  7.  realProps = new LocalProperties(ImmutableMap.of());
  8. }

代码示例来源：origin: apache/incubator-druid

  1. EasyMock.expect(tsqa.getTask(EasyMock.anyString())).andReturn(Optional.of(noopTask)).anyTimes();
  2. EasyMock.replay(tsqa);
  3. mockedOnceTsqa = true;
  4. EasyMock.expect(supervisorManager.getSupervisorSpec(EasyMock.anyString()))
  5.     .andReturn(Optional.of(supervisorSpec))
  6.     .anyTimes();

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void shouldAdjustCursorWhenInTrimmedResult() {
  3.  expect(delegate.parse(anyString(), eq(2), anyObject()))
  4.    .andReturn(parsedLine);
  5.  replay(delegate);
  6.  parser.parse("  line  ", 4, UNSPECIFIED);
  7. }

代码示例来源：origin: apache/incubator-druid

  1. @Test
  2. public void testServiceAnnouncementPOSTExceptionInHandler()
  3. {
  4.  final ListenerHandler handler = EasyMock.createStrictMock(ListenerHandler.class);
  5.  EasyMock.expect(handler.handlePOST(
  6.    EasyMock.anyObject(),
  7.    EasyMock.anyObject(),
  8.    EasyMock.anyString()
  9.  )).andThrow(new RuntimeException("test"));
  10.  final ListenerResource resource = new ListenerResource(
  11.    mapper,
  12.    mapper,
  13.    handler
  14.  )
  15.  {
  16.  };
  17.  EasyMock.replay(handler);
  18.  Assert.assertEquals(
  19.    Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(),
  20.    resource.serviceAnnouncementPOST("id", EMPTY_JSON_MAP.get(), req).getStatus()
  21.  );
  22.  EasyMock.verify(req, handler);
  23. }

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void shouldAdjustCursorIfInRightWhiteSpace() {
  3.  expect(delegate.parse(anyString(), eq(4), anyObject()))
  4.    .andReturn(parsedLine).anyTimes();
  5.  replay(delegate);
  6.  parser.parse("  line  ", 6, UNSPECIFIED);
  7.  parser.parse("  line  ", 7, UNSPECIFIED);
  8.  parser.parse("  line  ", 8, UNSPECIFIED);
  9. }

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void shouldAdjustCursorIfInLeftWhiteSpace() {
  3.  expect(delegate.parse(anyString(), eq(0), anyObject()))
  4.    .andReturn(parsedLine).anyTimes();
  5.  replay(delegate);
  6.  parser.parse("  line  ", 0, UNSPECIFIED);
  7.  parser.parse("  line  ", 1, UNSPECIFIED);
  8.  parser.parse("  line  ", 2, UNSPECIFIED);
  9. }

代码示例来源：origin: apache/incubator-druid

  1. EasyMock.expect(
  2.   segmentManager.getUnusedSegmentIntervals(
  3.     EasyMock.anyString(),
  4.     EasyMock.anyObject(Interval.class),
  5.     EasyMock.anyInt()

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void shouldMatchAvroFormatter() throws Exception {
  3.  // Given:
  4.  final Schema schema = parseAvroSchema(
  5.    "{\n" +
  6.    "    \"fields\": [\n" +
  7.    "        { \"name\": \"str1\", \"type\": \"string\" }\n" +
  8.    "    ],\n" +
  9.    "    \"name\": \"myrecord\",\n" +
  10.    "    \"type\": \"record\"\n" +
  11.    "}");
  12.  final GenericData.Record avroRecord = new GenericData.Record(schema);
  13.  avroRecord.put("str1", "My first string");
  14.  expect(schemaRegistryClient.register(anyString(), anyObject())).andReturn(1);
  15.  expect(schemaRegistryClient.getById(anyInt())).andReturn(schema).times(2);
  16.  replay(schemaRegistryClient);
  17.  final byte[] avroData = serializeAvroRecord(avroRecord);
  18.  // When:
  19.  final Result result = getFormatter(avroData);
  20.  // Then:
  21.  assertThat(result.format, is(Format.AVRO));
  22.  assertThat(result.formatted, endsWith(", key, {\"str1\": \"My first string\"}\n"));
  23. }

代码示例来源：origin: confluentinc/ksql

  1. @Test
  2. public void shouldReturn400OnBadStatement() throws Exception {
  3.  // Given:
  4.  reset(mockStatementParser);
  5.  expect(mockStatementParser.parseSingleStatement(anyString()))
  6.    .andThrow(new IllegalArgumentException("some error message"));
  7.  replay(mockStatementParser);
  8.  // Expect
  9.  expectedException.expect(KsqlRestException.class);
  10.  expectedException.expect(exceptionStatusCode(is(Code.BAD_REQUEST)));
  11.  expectedException.expect(exceptionKsqlErrorMessage(errorMessage(is("some error message"))));
  12.  expectedException.expect(
  13.    exceptionKsqlErrorMessage(errorCode(is(Errors.ERROR_CODE_BAD_STATEMENT))));
  14.  // When:
  15.  testResource.streamQuery(new KsqlRequest("query", Collections.emptyMap(), null));
  16. }

代码示例来源：origin: apache/incubator-druid

  1. EasyMock
  2.   .expect(
  3.     indexerMetadataStorageCoordinator.deletePendingSegments(EasyMock.anyString(), EasyMock.eq(deleteInterval))

代码示例来源：origin: apache/incubator-druid

  1. @Test
  2. public void testDeletePendingSegments()
  3. {
  4.  final List<TaskInfo<Task, TaskStatus>> taskInfos = ImmutableList.of(
  5.    new TaskInfo<>(
  6.      "id1",
  7.      DateTimes.of("2017-12-01"),
  8.      TaskStatus.running("id1"),
  9.      "dataSource",
  10.      NoopTask.create("id1", 0)
  11.    ),
  12.    new TaskInfo<>(
  13.      "id1",
  14.      DateTimes.of("2017-12-02"),
  15.      TaskStatus.running("id2"),
  16.      "dataSource",
  17.      NoopTask.create("id2", 0)
  18.    )
  19.  );
  20.  EasyMock.expect(taskStorageQueryAdapter.getActiveTaskInfo("dataSource")).andReturn(taskInfos);
  21.  final Interval deleteInterval = Intervals.of("2017-01-01/2017-12-01");
  22.  EasyMock
  23.    .expect(
  24.      indexerMetadataStorageCoordinator.deletePendingSegments(EasyMock.anyString(), EasyMock.eq(deleteInterval))
  25.    )
  26.    .andReturn(10);
  27.  EasyMock.replay(taskStorageQueryAdapter, indexerMetadataStorageCoordinator);
  28.  Assert.assertEquals(10, indexerMetadataStorageAdapter.deletePendingSegments("dataSource", deleteInterval));
  29. }

代码示例来源：origin: apache/incubator-druid

  1. .expect(
  2.     handoffNotifierFactory.createSegmentHandoffNotifier(EasyMock
  3.       .anyString())).andReturn(handoffNotifier).anyTimes();
  4. EasyMock
  5.   .expect(

内容来源于网络，如有侵权，请联系作者删除！

EasyMock

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    EasyMock类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com