SqsIntegrationTest.java 文件源码

/**
 * In the following test, we purposely setting the time offset to trigger a clock skew error.
 * The time offset must be fixed and then we validate the global value for time offset has been
 * update.
 */
@Test
public void clockSkewFailure_CorrectsGlobalTimeOffset() throws Exception {
    BasicConfigurator.configure();
    final int originalOffset = SdkGlobalTime.getGlobalTimeOffset();
    final int skew = 3600;

    SdkGlobalTime.setGlobalTimeOffset(skew);
    assertEquals(skew, SdkGlobalTime.getGlobalTimeOffset());
    SQSAsyncClient sqsClient = createSqsAyncClient();

    sqsClient.listQueues(ListQueuesRequest.builder().build()).thenCompose( __ -> {
        assertThat("Clockskew is fixed!", SdkGlobalTime.getGlobalTimeOffset(), lessThan(skew));
        // subsequent changes to the global time offset won't affect existing client
        SdkGlobalTime.setGlobalTimeOffset(skew);
        return sqsClient.listQueues(ListQueuesRequest.builder().build());
    }).thenAccept( __ ->  {
        assertEquals(skew, SdkGlobalTime.getGlobalTimeOffset());
    }).join();

    sqsClient.close();

    SdkGlobalTime.setGlobalTimeOffset(originalOffset);
}