本文整理了Java中org.easymock.Capture.newInstance()
方法的一些代码示例,展示了Capture.newInstance()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Capture.newInstance()
方法的具体详情如下:
包路径:org.easymock.Capture
类名称:Capture
方法名:newInstance
[英]Create a new capture instance that will keep only the last captured value
[中]创建一个新的捕获实例,该实例将只保留最后捕获的值
代码示例来源:origin: apache/incubator-druid
@Test
public void testReset()
{
Capture<String> id1 = Capture.newInstance();
Capture<String> id2 = Capture.newInstance();
EasyMock.expect(taskMaster.getSupervisorManager()).andReturn(Optional.of(supervisorManager)).times(2);
EasyMock.expect(supervisorManager.resetSupervisor(EasyMock.capture(id1), EasyMock.anyObject(DataSourceMetadata.class))).andReturn(true);
EasyMock.expect(supervisorManager.resetSupervisor(EasyMock.capture(id2), EasyMock.anyObject(DataSourceMetadata.class))).andReturn(false);
replayAll();
Response response = supervisorResource.reset("my-id");
Assert.assertEquals(200, response.getStatus());
Assert.assertEquals(ImmutableMap.of("id", "my-id"), response.getEntity());
response = supervisorResource.reset("my-id-2");
Assert.assertEquals(404, response.getStatus());
Assert.assertEquals("my-id", id1.getValue());
Assert.assertEquals("my-id-2", id2.getValue());
verifyAll();
resetAll();
EasyMock.expect(taskMaster.getSupervisorManager()).andReturn(Optional.absent());
replayAll();
response = supervisorResource.terminate("my-id");
Assert.assertEquals(503, response.getStatus());
verifyAll();
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testProjectGetWithOptions() {
Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(dnsRpcMock.getProject(EasyMock.capture(capturedOptions)))
.andReturn(PROJECT_INFO.toPb());
EasyMock.replay(dnsRpcMock);
dns = options.getService(); // creates DnsImpl
ProjectInfo projectInfo = dns.getProject(PROJECT_FIELDS);
String selector = (String) capturedOptions.getValue().get(PROJECT_FIELDS.getRpcOption());
assertEquals(PROJECT_INFO, projectInfo);
assertTrue(selector.contains(Dns.ProjectField.QUOTA.getSelector()));
assertTrue(selector.contains(Dns.ProjectField.PROJECT_ID.getSelector()));
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testCreateImageWithOptions() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(computeRpcMock.createImage(eq(IMAGE.toPb()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.create(IMAGE, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testCreateNetworkWithOptions() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(computeRpcMock.createNetwork(eq(NETWORK.toPb()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.create(NETWORK, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: apache/incubator-druid
@Test
public void testFailedNew() throws Exception
EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
LookupCoordinatorManager.class);
EasyMock.expect(lookupCoordinatorManager.updateLookups(
EasyMock.eq(SINGLE_TIER_MAP),
EasyMock.capture(auditInfoCapture)
)).andReturn(false).once();
EasyMock.replay(lookupCoordinatorManager, request);
);
Assert.assertEquals(500, response.getStatus());
Assert.assertEquals(ImmutableMap.of("error", "Unknown error updating configuration"), response.getEntity());
Assert.assertTrue(auditInfoCapture.hasCaptured());
final AuditInfo auditInfo = auditInfoCapture.getValue();
Assert.assertEquals(author, auditInfo.getAuthor());
Assert.assertEquals(comment, auditInfo.getComment());
Assert.assertEquals(ip, auditInfo.getIp());
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetZoneWithSelectedFields() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(computeRpcMock.getZone(eq(ZONE_ID.getZone()), capture(capturedOptions)))
.andReturn(ZONE.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Zone zone = compute.getZone(ZONE_ID.getZone(), ZONE_OPTION_FIELDS);
String selector = (String) capturedOptions.getValue().get(ZONE_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(ZONE, zone);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetRegionWithSelectedFields() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(computeRpcMock.getRegion(eq(REGION_ID.getRegion()), capture(capturedOptions)))
.andReturn(REGION.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Region region = compute.getRegion(REGION_ID.getRegion(), REGION_OPTION_FIELDS);
String selector = (String) capturedOptions.getValue().get(REGION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(REGION, region);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testDeleteSnapshotWithSelectedFields_Operation() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(
computeRpcMock.deleteSnapshot(eq(SNAPSHOT_ID.getSnapshot()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.deleteSnapshot(SNAPSHOT_ID, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testCreateGlobalAddressWithOptions() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(
computeRpcMock.createGlobalAddress(eq(GLOBAL_ADDRESS.toPb()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.create(GLOBAL_ADDRESS, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: apache/incubator-druid
@Test
public void testExceptionalNew() throws Exception
EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
LookupCoordinatorManager.class);
EasyMock.expect(lookupCoordinatorManager.updateLookups(
EasyMock.eq(SINGLE_TIER_MAP),
EasyMock.capture(auditInfoCapture)
)).andThrow(new RuntimeException(errMsg)).once();
EasyMock.replay(lookupCoordinatorManager, request);
);
Assert.assertEquals(500, response.getStatus());
Assert.assertEquals(ImmutableMap.of("error", errMsg), response.getEntity());
Assert.assertTrue(auditInfoCapture.hasCaptured());
final AuditInfo auditInfo = auditInfoCapture.getValue();
Assert.assertEquals(author, auditInfo.getAuthor());
Assert.assertEquals(comment, auditInfo.getComment());
Assert.assertEquals(ip, auditInfo.getIp());
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetZoneNotFound() {
EasyMock.reset(batchMock);
Capture<RpcBatch.Callback<ManagedZone>> callback = Capture.newInstance();
Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
batchMock.addGetZone(
EasyMock.eq(ZONE_NAME), EasyMock.capture(callback), EasyMock.capture(capturedOptions));
EasyMock.replay(batchMock);
DnsBatchResult<Zone> batchResult = dnsBatch.getZone(ZONE_NAME);
assertEquals(0, capturedOptions.getValue().size());
GoogleJsonError error = new GoogleJsonError();
error.setCode(404);
RpcBatch.Callback<ManagedZone> capturedCallback = callback.getValue();
capturedCallback.onFailure(error);
assertNull(batchResult.get());
}
代码示例来源:origin: apache/incubator-druid
@Test
public void testSimpleNew() throws Exception
EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
LookupCoordinatorManager.class);
EasyMock.expect(lookupCoordinatorManager.updateLookups(
EasyMock.eq(SINGLE_TIER_MAP),
EasyMock.capture(auditInfoCapture)
)).andReturn(true).once();
EasyMock.replay(lookupCoordinatorManager, request);
final LookupCoordinatorResource lookupCoordinatorResource = new LookupCoordinatorResource(
lookupCoordinatorManager,
);
Assert.assertEquals(202, response.getStatus());
Assert.assertTrue(auditInfoCapture.hasCaptured());
final AuditInfo auditInfo = auditInfoCapture.getValue();
Assert.assertEquals(author, auditInfo.getAuthor());
Assert.assertEquals(comment, auditInfo.getComment());
Assert.assertEquals(ip, auditInfo.getIp());
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testDeleteNetworkWithSelectedFields_Operation() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(
computeRpcMock.deleteNetwork(eq(NETWORK_ID.getNetwork()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.deleteNetwork(NETWORK_ID, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testDeleteGlobalAddressWithSelectedFields_Operation() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(
computeRpcMock.deleteGlobalAddress(
eq(GLOBAL_ADDRESS_ID.getAddress()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.deleteAddress(GLOBAL_ADDRESS_ID, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetGlobalOperationWithSelectedFields() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(
computeRpcMock.getGlobalOperation(
eq(GLOBAL_OPERATION_ID.getOperation()), capture(capturedOptions)))
.andReturn(globalOperation.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
Operation operation = compute.getOperation(GLOBAL_OPERATION_ID, OPERATION_OPTION_FIELDS);
String selector =
(String) capturedOptions.getValue().get(OPERATION_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("id"));
assertTrue(selector.contains("description"));
assertEquals(23, selector.length());
assertEquals(globalOperation, operation);
}
代码示例来源:origin: apache/incubator-druid
@Test
public void testExceptionalDelete()
EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
LookupCoordinatorManager.class);
EasyMock.expect(lookupCoordinatorManager.deleteLookup(
EasyMock.eq(LOOKUP_TIER),
EasyMock.eq(LOOKUP_NAME),
EasyMock.capture(auditInfoCapture)
)).andThrow(new RuntimeException(errMsg)).once();
EasyMock.replay(lookupCoordinatorManager, request);
);
Assert.assertEquals(500, response.getStatus());
Assert.assertEquals(ImmutableMap.of("error", errMsg), response.getEntity());
Assert.assertTrue(auditInfoCapture.hasCaptured());
final AuditInfo auditInfo = auditInfoCapture.getValue();
Assert.assertEquals(author, auditInfo.getAuthor());
Assert.assertEquals(comment, auditInfo.getComment());
Assert.assertEquals(ip, auditInfo.getIp());
代码示例来源:origin: apache/incubator-druid
@Test
public void testSimpleDelete()
EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
LookupCoordinatorManager.class);
EasyMock.expect(lookupCoordinatorManager.deleteLookup(
EasyMock.eq(LOOKUP_TIER),
EasyMock.eq(LOOKUP_NAME),
EasyMock.capture(auditInfoCapture)
)).andReturn(true).once();
EasyMock.replay(lookupCoordinatorManager, request);
);
Assert.assertEquals(202, response.getStatus());
Assert.assertTrue(auditInfoCapture.hasCaptured());
final AuditInfo auditInfo = auditInfoCapture.getValue();
Assert.assertEquals(author, auditInfo.getAuthor());
Assert.assertEquals(comment, auditInfo.getComment());
Assert.assertEquals(ip, auditInfo.getIp());
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetLicenseFromStringWithOptions() {
Capture<Map<ComputeRpc.Option, Object>> capturedOptions = Capture.newInstance();
EasyMock.expect(
computeRpcMock.getLicense(
eq(PROJECT), eq(LICENSE_ID.getLicense()), capture(capturedOptions)))
.andReturn(LICENSE.toPb());
EasyMock.replay(computeRpcMock);
compute = options.getService();
License license = compute.getLicense(LICENSE_ID.getLicense(), LICENSE_OPTION_FIELDS);
assertEquals(LICENSE, license);
String selector = (String) capturedOptions.getValue().get(LICENSE_OPTION_FIELDS.getRpcOption());
assertTrue(selector.contains("selfLink"));
assertTrue(selector.contains("chargesUseFee"));
assertEquals(22, selector.length());
assertEquals(LICENSE, license);
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetProjectWithOptions() {
EasyMock.reset(batchMock);
Capture<RpcBatch.Callback<Project>> callback = Capture.newInstance();
Capture<Map<DnsRpc.Option, Object>> capturedOptions = Capture.newInstance();
batchMock.addGetProject(EasyMock.capture(callback), EasyMock.capture(capturedOptions));
EasyMock.replay(batchMock);
DnsBatchResult<ProjectInfo> batchResult = dnsBatch.getProject(PROJECT_FIELDS);
assertNotNull(callback.getValue());
String selector = (String) capturedOptions.getValue().get(PROJECT_FIELDS.getRpcOption());
assertTrue(selector.contains(Dns.ProjectField.QUOTA.getSelector()));
assertTrue(selector.contains(Dns.ProjectField.PROJECT_ID.getSelector()));
RpcBatch.Callback<Project> capturedCallback = callback.getValue();
capturedCallback.onSuccess(PROJECT_INFO.toPb());
assertEquals(PROJECT_INFO, batchResult.get());
}
代码示例来源:origin: apache/incubator-druid
@Test
public void testDBErrNewLookup() throws Exception
EasyMock.expect(request.getContentType()).andReturn(MediaType.APPLICATION_JSON).once();
EasyMock.expect(request.getRemoteAddr()).andReturn(ip).once();
final Capture<AuditInfo> auditInfoCapture = Capture.newInstance();
final LookupCoordinatorManager lookupCoordinatorManager = EasyMock.createStrictMock(
LookupCoordinatorManager.class);
EasyMock.expect(lookupCoordinatorManager.updateLookup(
EasyMock.eq(LOOKUP_TIER),
EasyMock.eq(LOOKUP_NAME),
EasyMock.eq(SINGLE_LOOKUP),
EasyMock.capture(auditInfoCapture)
)).andReturn(false).once();
EasyMock.replay(lookupCoordinatorManager, request);
);
Assert.assertEquals(500, response.getStatus());
Assert.assertEquals(ImmutableMap.of("error", "Unknown error updating configuration"), response.getEntity());
Assert.assertTrue(auditInfoCapture.hasCaptured());
final AuditInfo auditInfo = auditInfoCapture.getValue();
Assert.assertEquals(author, auditInfo.getAuthor());
Assert.assertEquals(comment, auditInfo.getComment());
Assert.assertEquals(ip, auditInfo.getIp());
内容来源于网络,如有侵权,请联系作者删除!