in src/main/java/org/elasticsearch/aliyun/oss/service/OssStorageClient.java [191:210]
public void refreshStsOssClient() throws CreateStsOssClientException {
int retryCount = 0;
while (isStsTokenExpired() || isTokenWillExpired()) {
retryCount++;
if (retryCount > REFRESH_RETRY_COUNT) {
logger.error("Can't get valid token after retry {} times", REFRESH_RETRY_COUNT);
throw new CreateStsOssClientException(
"Can't get valid token after retry " + REFRESH_RETRY_COUNT + " times");
}
this.client = createStsOssClient(this.metadata);
try {
if (isStsTokenExpired() || isTokenWillExpired()) {
sleep(IN_TOKEN_EXPIRED_MS * 2);
}
} catch (InterruptedException e) {
logger.error("refresh sleep exception", e);
throw new CreateStsOssClientException(e);
}
}
}