diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractCassandraConfiguration.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractCassandraConfiguration.java index 4e847faf0..512b74847 100644 --- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractCassandraConfiguration.java +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractCassandraConfiguration.java @@ -24,7 +24,6 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.convert.converter.Converter; import org.springframework.data.cassandra.SessionFactory; -import org.springframework.data.cassandra.core.CassandraAdminOperations; import org.springframework.data.cassandra.core.CassandraAdminTemplate; import org.springframework.data.cassandra.core.convert.CassandraConverter; import org.springframework.data.cassandra.core.convert.CassandraCustomConversions; @@ -196,7 +195,7 @@ public abstract class AbstractCassandraConfiguration extends AbstractClusterConf * @throws Exception if the {@link com.datastax.driver.core.Session} could not be obtained. */ @Bean - public CassandraAdminOperations cassandraTemplate() throws Exception { + public CassandraAdminTemplate cassandraTemplate() throws Exception { return new CassandraAdminTemplate(sessionFactory(), cassandraConverter()); } diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractReactiveCassandraConfiguration.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractReactiveCassandraConfiguration.java index 838ec5f97..4ac8c867b 100644 --- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractReactiveCassandraConfiguration.java +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/config/AbstractReactiveCassandraConfiguration.java @@ -19,7 +19,6 @@ import org.springframework.context.annotation.Bean; import org.springframework.data.cassandra.ReactiveSession; import org.springframework.data.cassandra.ReactiveSessionFactory; import org.springframework.data.cassandra.core.CassandraAdminTemplate; -import org.springframework.data.cassandra.core.ReactiveCassandraOperations; import org.springframework.data.cassandra.core.ReactiveCassandraTemplate; import org.springframework.data.cassandra.core.cql.ReactiveCqlOperations; import org.springframework.data.cassandra.core.cql.ReactiveCqlTemplate; @@ -64,12 +63,12 @@ public abstract class AbstractReactiveCassandraConfiguration extends AbstractCas /** * Creates a {@link CassandraAdminTemplate}. * - * @return the {@link ReactiveCassandraOperations}. + * @return the {@link ReactiveCassandraTemplate}. * @see #reactiveSessionFactory() * @see #cassandraConverter() */ @Bean - public ReactiveCassandraOperations reactiveCassandraTemplate() { + public ReactiveCassandraTemplate reactiveCassandraTemplate() { return new ReactiveCassandraTemplate(reactiveSessionFactory(), cassandraConverter()); } @@ -80,7 +79,7 @@ public abstract class AbstractReactiveCassandraConfiguration extends AbstractCas * @see #reactiveSessionFactory() */ @Bean - public ReactiveCqlOperations reactiveCqlTemplate() { + public ReactiveCqlTemplate reactiveCqlTemplate() { return new ReactiveCqlTemplate(reactiveSessionFactory()); } }