CODEWITHSUNDEEP
spring-dataspring-data-cassandra
JoshRo
JoshRo

Reputation: 31

How to load spring application context even if Cassandra down

When using 

@Configuration
@EnableCassandraRepositories(basePackages={"com.foo"})
public class CassandraConfig{
@Bean
    public CassandraClusterFactoryBean cluster()
    {

        final CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
        cluster.setContactPoints(nodesRead);
        cluster.setPort(port);

        return cluster;
    }

Where in the com.foo package there is a interface that extends CrudRepository.

Is there a way to make it so that at startup time an exception is not thrown if the database is down?

Ideally what occurs is that we startup and anytime you call a method on the repository, it will first attempt to connect to the database and then if the database is still down return an error saying can't connect.

The behavior I currently observe is that NoHostAvailableException is thrown and the web container does not start up.

Upvotes: 1

Views: 1068

Answers (1)

JoshRo
JoshRo

Reputation: 31

I was able to come up with a solution. I removed the @EnableCassandraRepositories(basePackages={"com.foo"}) annotation from the repository and defined a Bean in my Config that would return my repository. Removing the EnableCassandraRepositories allowed lazy loading of the repository. This new bean in my Config allowed me to instantiate my repository using the RepositoryFactorySupport getRepository() method. I annotated this bean as lazy and made sure references to the bean were also lazy.

Assume my repository looks like the following

public interface IBarRepository extends CrudRepository<Bar, BarKey>{}

My Config file now looks like

@Configuration

public class CassandraConfig{
@Bean
@Lazy(value=true)
public IBarRepository barRepository() throws Exception    
{
  final RepositoryFactorySupport support = CassandraRepositoryFactory(cassandraTemplate());
  return support.getRepository(IBarRepository.class); 
}
@Bean
@Lazy(value=true)
public CassandraClusterFactoryBean cluster()
{

    final CassandraClusterFactoryBean cluster = new   CassandraClusterFactoryBean();
    cluster.setContactPoints(nodesRead);
    cluster.setPort(port);

    return cluster;
}
//More beans down here defining things like cluster, mappingContext, session, etc.

Upvotes: 2

Related Questions