@Component
public class AwsDynamoDBConfiguration {
Logger logger = LoggerFactory.getLogger(AwsDynamoDBConfiguration.class);
/**
* AWS configuration.
*/
@Autowired
private AwsConfiguration awsConfiguration;
private static final AwsClientBuilder.EndpointConfiguration DYNAMODB_ENDPOINT = new AwsClientBuilder.EndpointConfiguration(
"https://dynamodb.us-east-1.amazonaws.com", "us-east-1");
private Optional<LockItem> lockItem;
private AmazonDynamoDBLockClient client;
public boolean lockDynamoDB() throws InterruptedException, IOException {
logger.info("Start : AWS DynamoDB lockDynamoDB");
boolean isDynamoDBLockAccessed = false;
final AmazonDynamoDB dynamoDB = AmazonDynamoDBClientBuilder.standard()
.withEndpointConfiguration(DYNAMODB_ENDPOINT)
.withCredentials(new AWSStaticCredentialsProvider(
new BasicAWSCredentials("access_key", "secret_key")))
.build();
logger.info("DynamoDB created.");
// Whether or not to create a heartbeating background thread
final boolean createHeartbeatBackgroundThread = true;
// build the lock client
client = new AmazonDynamoDBLockClient(AmazonDynamoDBLockClientOptions.builder(dynamoDB, "tbl_test_lock")
.withTimeUnit(TimeUnit.SECONDS).withLeaseDuration(100L).withHeartbeatPeriod(3L)
.withCreateHeartbeatBackgroundThread(createHeartbeatBackgroundThread).build());
logger.info("DynamoDB Client created.");
// try to acquire a lock on the partition key "key"
lockItem = client.tryAcquireLock(AcquireLockOptions.builder("key").build());
logger.info("DynamoDB try acquire lock.");
if (lockItem.isPresent()) {
logger.info("Acquired lock! If I die, my lock will expire in 10 seconds.");
logger.info("Otherwise, I will hold it until I stop heartbeating.");
isDynamoDBLockAccessed = true;
} else {
logger.info("Failed to acquire lock!");
isDynamoDBLockAccessed = false;
}
client.close();
logger.info("End : AWS DynamoDB lockDynamoDB");
return isDynamoDBLockAccessed;
}
@PreDestroy
public void destroy() {
logger.info("AWS DynamoDB Callback triggered - @PreDestroy.");
if (client != null && lockItem != null && lockItem.isPresent()) {
client.releaseLock(lockItem.get());
}
logger.info("AWS DynamoDB Lock has been released.");
}
}

if (lockItem.isPresent()) {
client.getLock("key", Optional.empty());
logger.info("Acquired lock! If I die, my lock will expire in " + leaseDuration + " seconds.");
logger.info("Otherwise, I will hold it until I stop heartbeating.");
isDynamoDBLockAccessed = true;
} else {
logger.info("Failed to acquire lock!");
isDynamoDBLockAccessed = false;
}