/**
* 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);
}
SqsIntegrationTest.java 文件源码
java
阅读 22
收藏 0
点赞 0
评论 0
项目:aws-sdk-java-v2
作者:
评论列表
文章目录