io.awspring.cloud.jdbc.retry

Class DatabaseInstanceStatusRetryPolicy

java.lang.Object

io.awspring.cloud.jdbc.retry.DatabaseInstanceStatusRetryPolicy

All Implemented Interfaces:

Serializable, org.springframework.retry.RetryPolicy

public class DatabaseInstanceStatusRetryPolicy
extends Object
implements org.springframework.retry.RetryPolicy

RetryPolicy implementation that checks if it is useful to retry an operation based on the database instance status. This class retrieves that database state and verifies through the InstanceStatus enum operation if it is useful to retry the operation. This class does not retrieve the status if there is no Throwable registered to avoid any performance implication during normal operations.

This class should not be used alone because this would lead into a infinite retry, because this class does not limit the amount of retries. Consider using this class together with the SqlRetryPolicy which limits the maximum number of retries.

Since:

1.0

Author:

Agim Emruli

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DatabaseInstanceStatusRetryPolicy(com.amazonaws.services.rds.AmazonRDS amazonRDS, String dbInstanceIdentifier) Constructs this strategy implementation with it default and mandatory collaborators.

Method Summary

Modifier and Type	Method and Description
boolean	canRetry(org.springframework.retry.RetryContext context) Implementation that checks if there is an exception registered through registerThrowable(org.springframework.retry.RetryContext, Throwable).
void	close(org.springframework.retry.RetryContext context)
org.springframework.retry.RetryContext	open(org.springframework.retry.RetryContext parent)
void	registerThrowable(org.springframework.retry.RetryContext context, Throwable throwable)
void	setResourceIdResolver(ResourceIdResolver resourceIdResolver) Configures an option.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatabaseInstanceStatusRetryPolicy

public DatabaseInstanceStatusRetryPolicy(com.amazonaws.services.rds.AmazonRDS amazonRDS,
                                         String dbInstanceIdentifier)

Constructs this strategy implementation with it default and mandatory collaborators.

Parameters:

amazonRDS - - used to query the Amazon RDS service, must not be null

dbInstanceIdentifier - - database instance for which this class should check the state.

Method Detail

setResourceIdResolver

public void setResourceIdResolver(ResourceIdResolver resourceIdResolver)

Configures an option. ResourceIdResolver to resolve logical name to physical name

Parameters:

resourceIdResolver - - the resourceIdResolver to be used, may be null

canRetry

public boolean canRetry(org.springframework.retry.RetryContext context)

Implementation that checks if there is an exception registered through registerThrowable(org.springframework.retry.RetryContext, Throwable). Returns true if there is no exception registered at all and verifies the database instance status if there is one registered.

Specified by:

canRetry in interface org.springframework.retry.RetryPolicy

Parameters:

context - - the retry context which may contain a registered exception

Returns:

true if there is no exception registered or if there is a retry useful which is verified by the InstanceStatus enum.

open

public org.springframework.retry.RetryContext open(org.springframework.retry.RetryContext parent)

Specified by:

open in interface org.springframework.retry.RetryPolicy

close

public void close(org.springframework.retry.RetryContext context)

Specified by:

close in interface org.springframework.retry.RetryPolicy

registerThrowable

public void registerThrowable(org.springframework.retry.RetryContext context,
                              Throwable throwable)

Specified by:

registerThrowable in interface org.springframework.retry.RetryPolicy