dropwizard-cassandra

config.yml

# using an exponential reconnection policy
reconnectionPolicy:
  type: exponential
  baseDelay: 10 milliseconds
  maxDelay: 1 second

# using a constant reconnection policy
reconnectionPolicy:
  type: constant
  delay: 10 milliseconds

pom.xml

<dependency>
  <groupId>org.stuartgunter</groupId>
  <artifactId>dropwizard-cassandra</artifactId>
  <version>${dropwizard-cassandra.version}</version>
</dependency>

YourApp.java

public class YourApp extends Application<YourAppConfig> {
    private final CassandraBundle<YourAppConfig> cassandra =
            new CassandraBundle<YourAppConfig>() {
                @Override
                protected CassandraFactory cassandraConfiguration(YourAppConfig appConfig) {
                    return appConfig.getCassandraConfig();
                }
            };

    @Override
    public void initialize(Bootstrap<CassandraBundleConfiguration> bootstrap) {
        bootstrap.addBundle(cassandra);
    }

    @Override
    public void run(YourAppConfig configuration, Environment environment) throws Exception {
        /*
         * you can now use `cassandra.getCluster()` to use the cluster instance in your app,
         * or pass around a SessionFactory with `cassandra.getSessionFactory()` if you just need
         * to be able to create new sessions without knowing whether a keyspace was configured
         */
    }
}