com.amazonaws.services.s3.model.ListPartsRequest#org.assertj.core.api.Fail源码实例Demo

下面列出了com.amazonaws.services.s3.model.ListPartsRequest#org.assertj.core.api.Fail 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： ditto 文件： ConnectionLoggerRegistryTest.java

private void addLogEntriesUntilMaxSizeIsExceeded(final ConnectionLogger logger) throws InterruptedException {
    final long maxSize = TestConstants.MONITORING_CONFIG.logger().maxLogSizeInBytes();
    final int maxFailureLogs = TestConstants.MONITORING_CONFIG.logger().failureCapacity();
    int currentFailureLogs = 0;

    while (getCurrentLogsSize(logger) < maxSize) {
        logger.failure(randomInfoProvider());
        TimeUnit.MILLISECONDS.sleep(1); // ensure different timestamps to make ordering assertion stable

        if (++currentFailureLogs > maxFailureLogs) {
            Fail.fail("Breaking the while loop as I can't create enough failure logs to trigger the "
            + "max logs size. Review the logger config and find fitting config values for the maxLogSizeInBytes "
            + "and the failure capacity.");
        }
    }
}

源代码2 项目： camunda-engine-dmn 文件： DmnDecisionResultTest.java

protected void assertMultipleOutputValues(DmnDecisionResultEntries result) {
  assertThat(result.size()).isEqualTo(2);

  String value = (String) result.get("firstOutput");
  assertThat(value).isEqualTo("multipleValues1");

  value = (String) result.get("secondOutput");
  assertThat(value).isEqualTo("multipleValues2");

  value = result.getFirstEntry();
  assertThat(value).isEqualTo("multipleValues1");

  try {
    result.getSingleEntry();
    Fail.failBecauseExceptionWasNotThrown(DmnDecisionResultException.class);
  }
  catch (DmnDecisionResultException e) {
    assertThat(e)
      .hasMessageStartingWith("DMN-01010")
      .hasMessageContaining("multipleValues1")
      .hasMessageContaining("multipleValues2");
  }
}

源代码3 项目： camunda-engine-dmn 文件： DmnDecisionTableResultTest.java

protected void assertMultipleOutputValues(DmnDecisionRuleResult decisionRuleResult) {
  assertThat(decisionRuleResult.size()).isEqualTo(2);

  String value = (String) decisionRuleResult.get("firstOutput");
  assertThat(value).isEqualTo("multipleValues1");

  value = (String) decisionRuleResult.get("secondOutput");
  assertThat(value).isEqualTo("multipleValues2");

  value = decisionRuleResult.getFirstEntry();
  assertThat(value).isEqualTo("multipleValues1");

  try {
    decisionRuleResult.getSingleEntry();
    Fail.failBecauseExceptionWasNotThrown(DmnDecisionResultException.class);
  }
  catch (DmnDecisionResultException e) {
    assertThat(e)
      .hasMessageStartingWith("DMN-01007")
      .hasMessageContaining("multipleValues1")
      .hasMessageContaining("multipleValues2");
  }
}

源代码4 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testAwsV4SignatureBadIdentity() throws Exception {
    client = AmazonS3ClientBuilder.standard()
            .withCredentials(new AWSStaticCredentialsProvider(
                    new BasicAWSCredentials(
                            "bad-access-key", awsCreds.getAWSSecretKey())))
            .withEndpointConfiguration(s3EndpointConfig)
            .build();

    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentLength(BYTE_SOURCE.size());

    try {
        client.putObject(containerName, "foo",
                BYTE_SOURCE.openStream(), metadata);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("InvalidAccessKeyId");
    }
}

源代码5 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testAwsV4SignatureBadCredential() throws Exception {
    client = AmazonS3ClientBuilder.standard()
            .withCredentials(new AWSStaticCredentialsProvider(
                    new BasicAWSCredentials(
                            awsCreds.getAWSAccessKeyId(),
                            "bad-secret-key")))
            .withEndpointConfiguration(s3EndpointConfig)
            .build();

    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentLength(BYTE_SOURCE.size());

    try {
        client.putObject(containerName, "foo",
                BYTE_SOURCE.openStream(), metadata);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("SignatureDoesNotMatch");
    }
}

源代码6 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testUpdateBlobXmlAcls() throws Exception {
    assumeTrue(!Quirks.NO_BLOB_ACCESS_CONTROL.contains(blobStoreType));
    String blobName = "testUpdateBlobXmlAcls-blob";
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentLength(BYTE_SOURCE.size());
    client.putObject(containerName, blobName, BYTE_SOURCE.openStream(),
            metadata);
    AccessControlList acl = client.getObjectAcl(containerName, blobName);

    acl.grantPermission(GroupGrantee.AllUsers, Permission.Read);
    client.setObjectAcl(containerName, blobName, acl);
    assertThat(client.getObjectAcl(containerName, blobName)).isEqualTo(acl);

    acl.revokeAllPermissions(GroupGrantee.AllUsers);
    client.setObjectAcl(containerName, blobName, acl);
    assertThat(client.getObjectAcl(containerName, blobName)).isEqualTo(acl);

    acl.grantPermission(GroupGrantee.AllUsers, Permission.Write);
    try {
        client.setObjectAcl(containerName, blobName, acl);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("NotImplemented");
    }
}

源代码7 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testPartNumberMarker() throws Exception {
    String blobName = "foo";
    InitiateMultipartUploadResult result = client.initiateMultipartUpload(
            new InitiateMultipartUploadRequest(containerName, blobName));
    ListPartsRequest request = new ListPartsRequest(containerName,
            blobName, result.getUploadId());

    client.listParts(request.withPartNumberMarker(0));

    try {
        client.listParts(request.withPartNumberMarker(1));
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("NotImplemented");
    }
}

源代码8 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testBlobRemove() throws Exception {
    String blobName = "blob";
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentLength(BYTE_SOURCE.size());
    client.putObject(containerName, blobName, BYTE_SOURCE.openStream(),
            metadata);
    assertThat(client.getObjectMetadata(containerName, blobName))
            .isNotNull();

    client.deleteObject(containerName, blobName);
    try {
        client.getObjectMetadata(containerName, blobName);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("404 Not Found");
    }

    client.deleteObject(containerName, blobName);
}

源代码9 项目： RDFUnit 文件： TestCaseWithTargetTest.java

@Test
public void test() {

    TestCase innerTestCAse = Mockito.mock(TestCase.class);
    when(innerTestCAse.getSparqlWhere()).thenReturn(sparqlQuery);

    TestCase testCaseWithTarget = TestCaseWithTarget.builder()
            .testCase(innerTestCAse)
            .target(target)
            .filterSparql(" ?this <http://example.cpm/p> ?value .")
            .build();

    String finalSparql = PrefixNSService.getSparqlPrefixDecl() + testCaseWithTarget.getSparqlWhere();

    assertThat(finalSparql)
            .contains(target.getPattern());

    try {
        QueryFactory.create(finalSparql);
    } catch (Exception e) {
        Fail.fail("Failed sparql query:\n" + finalSparql, e);
    }

}

源代码10 项目： camunda-bpm-platform 文件： DmnDecisionResultTest.java

protected void assertMultipleOutputValues(DmnDecisionResultEntries result) {
  assertThat(result.size()).isEqualTo(2);

  String value = (String) result.get("firstOutput");
  assertThat(value).isEqualTo("multipleValues1");

  value = (String) result.get("secondOutput");
  assertThat(value).isEqualTo("multipleValues2");

  value = result.getFirstEntry();
  assertThat(value).isEqualTo("multipleValues1");

  try {
    result.getSingleEntry();
    Fail.failBecauseExceptionWasNotThrown(DmnDecisionResultException.class);
  }
  catch (DmnDecisionResultException e) {
    assertThat(e)
      .hasMessageStartingWith("DMN-01010")
      .hasMessageContaining("multipleValues1")
      .hasMessageContaining("multipleValues2");
  }
}

源代码11 项目： camunda-bpm-platform 文件： DmnDecisionTableResultTest.java

protected void assertMultipleOutputValues(DmnDecisionRuleResult decisionRuleResult) {
  assertThat(decisionRuleResult.size()).isEqualTo(2);

  String value = (String) decisionRuleResult.get("firstOutput");
  assertThat(value).isEqualTo("multipleValues1");

  value = (String) decisionRuleResult.get("secondOutput");
  assertThat(value).isEqualTo("multipleValues2");

  value = decisionRuleResult.getFirstEntry();
  assertThat(value).isEqualTo("multipleValues1");

  try {
    decisionRuleResult.getSingleEntry();
    Fail.failBecauseExceptionWasNotThrown(DmnDecisionResultException.class);
  }
  catch (DmnDecisionResultException e) {
    assertThat(e)
      .hasMessageStartingWith("DMN-01007")
      .hasMessageContaining("multipleValues1")
      .hasMessageContaining("multipleValues2");
  }
}

源代码12 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testDeleteMultipleObjectsEmpty() throws Exception {
    DeleteObjectsRequest request = new DeleteObjectsRequest(containerName)
            .withKeys();

    try {
        client.deleteObjects(request);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("MalformedXML");
    }
}

源代码13 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testContainerExists() throws Exception {
    client.headBucket(new HeadBucketRequest(containerName));
    try {
        client.headBucket(new HeadBucketRequest(
                createRandomContainerName()));
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("404 Not Found");
    }
}

源代码14 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testContainerCreateDelete() throws Exception {
    String containerName2 = createRandomContainerName();
    client.createBucket(containerName2);
    try {
        client.createBucket(containerName2);
        client.deleteBucket(containerName2);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("BucketAlreadyOwnedByYou");
    }
}

源代码15 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testContainerDelete() throws Exception {
    client.headBucket(new HeadBucketRequest(containerName));
    client.deleteBucket(containerName);
    try {
        client.headBucket(new HeadBucketRequest(containerName));
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("404 Not Found");
    }
}

源代码16 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testUnknownHeader() throws Exception {
    String blobName = "test-unknown-header";
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentLength(BYTE_SOURCE.size());
    PutObjectRequest request = new PutObjectRequest(
            containerName, blobName, BYTE_SOURCE.openStream(), metadata)
            .withTagging(new ObjectTagging(ImmutableList.<Tag>of()));
    try {
        client.putObject(request);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("NotImplemented");
    }
}

源代码17 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testGetBucketPolicy() throws Exception {
    try {
        client.getBucketPolicy(containerName);
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("NoSuchPolicy");
    }
}

源代码18 项目： s3proxy 文件： AwsSdkTest.java

@Test
public void testUnknownParameter() throws Exception {
    try {
        client.setBucketLoggingConfiguration(
                new SetBucketLoggingConfigurationRequest(
                        containerName, new BucketLoggingConfiguration()));
        Fail.failBecauseExceptionWasNotThrown(AmazonS3Exception.class);
    } catch (AmazonS3Exception e) {
        assertThat(e.getErrorCode()).isEqualTo("NotImplemented");
    }
}

源代码19 项目： s3proxy 文件： JcloudsS3ClientLiveTest.java

@Override
@Test
public void testPublicWriteOnObject() throws InterruptedException,
        ExecutionException, TimeoutException, IOException {
    try {
        super.testPublicWriteOnObject();
        Fail.failBecauseExceptionWasNotThrown(AWSResponseException.class);
    } catch (AWSResponseException are) {
        assertThat(are.getError().getCode()).isEqualTo("NotImplemented");
        throw new SkipException("public-read-write-acl not supported", are);
    }
}

源代码20 项目： s3proxy 文件： JcloudsS3ClientLiveTest.java

@Override
@Test
public void testUpdateObjectACL() throws InterruptedException,
        ExecutionException, TimeoutException, IOException {
    try {
        super.testUpdateObjectACL();
        Fail.failBecauseExceptionWasNotThrown(AWSResponseException.class);
    } catch (AWSResponseException are) {
        assertThat(are.getError().getCode()).isEqualTo("NotImplemented");
        throw new SkipException("XML ACLs not supported", are);
    }
}

源代码21 项目： s3proxy 文件： ReadOnlyBlobStoreTest.java

@Test
public void testPutBlob() throws Exception {
    try {
        readOnlyBlobStore.putBlob(containerName, null);
        Fail.failBecauseExceptionWasNotThrown(
                UnsupportedOperationException.class);
    } catch (UnsupportedOperationException ne) {
        // expected
    }
}

源代码22 项目： s3proxy 文件： ReadOnlyBlobStoreTest.java

@Test
public void testPutBlobOptions() throws Exception {
    try {
        readOnlyBlobStore.putBlob(containerName, null, new PutOptions());
        Fail.failBecauseExceptionWasNotThrown(
                UnsupportedOperationException.class);
    } catch (UnsupportedOperationException ne) {
        // expected
    }
}

源代码23 项目： s3proxy 文件： JcloudsBucketsLiveTest.java

@Override
@Test
public void testUpdateBucketACL() throws Exception {
    try {
        super.testUpdateBucketACL();
        Fail.failBecauseExceptionWasNotThrown(AWSResponseException.class);
    } catch (AWSResponseException are) {
        assertThat(are.getError().getCode()).isEqualTo("NotImplemented");
        throw new SkipException("XML ACLs not supported", are);
    }
}

源代码24 项目： s3proxy 文件： JcloudsBucketsLiveTest.java

@Override
@Test
public void testBucketPayer() throws Exception {
    try {
        super.testBucketPayer();
        Fail.failBecauseExceptionWasNotThrown(AWSResponseException.class);
    } catch (AWSResponseException are) {
        assertThat(are.getError().getCode()).isEqualTo("NotImplemented");
        throw new SkipException("bucket payer not supported", are);
    }
}

源代码25 项目： s3proxy 文件： JcloudsBucketsLiveTest.java

@Override
@Test
public void testBucketLogging() throws Exception {
    try {
        super.testBucketLogging();
        Fail.failBecauseExceptionWasNotThrown(AWSResponseException.class);
    } catch (AWSResponseException are) {
        assertThat(are.getError().getCode()).isEqualTo("NotImplemented");
        throw new SkipException("bucket logging not supported", are);
    }
}

源代码26 项目： seed 文件： TransactionPluginTest.java

@Test
public void isTransactionalTest() {
    try {
        Assertions.assertThat(
                pluginUnderTest.isTransactional(this.getClass().getDeclaredMethod("testTransactional"))).isTrue();
    } catch (SecurityException | NoSuchMethodException e) {
        Fail.fail(e.getMessage());
    }
}

源代码27 项目： feign 文件： DefaultContractTest.java

@Test
public void formParamAndBodyParams() throws Exception {
  thrown.expect(IllegalStateException.class);
  thrown.expectMessage("Body parameters cannot be used with form parameters.");

  parseAndValidateMetadata(FormParams.class,
      "formParamAndBodyParams", String.class, String.class);
  Fail.failBecauseExceptionWasNotThrown(IllegalStateException.class);
}

源代码28 项目： feign 文件： DefaultContractTest.java

@Test
public void bodyParamsAndformParam() throws Exception {
  thrown.expect(IllegalStateException.class);
  thrown.expectMessage("Body parameters cannot be used with form parameters.");

  parseAndValidateMetadata(FormParams.class,
      "bodyParamsAndformParam", String.class, String.class);
  Fail.failBecauseExceptionWasNotThrown(IllegalStateException.class);
}

源代码29 项目： feign 文件： DefaultContractTest.java

@Test
public void onlyOneQueryMapAnnotationPermitted() throws Exception {
  try {
    parseAndValidateMetadata(QueryMapTestInterface.class, "multipleQueryMap", Map.class,
        Map.class);
    Fail.failBecauseExceptionWasNotThrown(IllegalStateException.class);
  } catch (final IllegalStateException ex) {
    assertThat(ex).hasMessage("QueryMap annotation was present on multiple parameters.");
  }
}

源代码30 项目： feign 文件： DefaultContractTest.java

@Test
public void queryMapKeysMustBeStrings() throws Exception {
  try {
    parseAndValidateMetadata(QueryMapTestInterface.class, "nonStringKeyQueryMap", Map.class);
    Fail.failBecauseExceptionWasNotThrown(IllegalStateException.class);
  } catch (final IllegalStateException ex) {
    assertThat(ex).hasMessage("QueryMap key must be a String: Integer");
  }
}

方法所在类

com.amazonaws.services.s3.model.ListPartsRequest