diff --git a/src/main/asciidoc/reference/reactive-cassandra.adoc b/src/main/asciidoc/reference/reactive-cassandra.adoc index 29135d407..5b059cdb9 100644 --- a/src/main/asciidoc/reference/reactive-cassandra.adoc +++ b/src/main/asciidoc/reference/reactive-cassandra.adoc @@ -159,7 +159,7 @@ public class CassandraApplication { Cluster cluster = Cluster.builder().addContactPoints("localhost").build(); Session session = cluster.connect("mykeyspace"); - ReactiveCassandraOperations template = new ReactiveCassandraTemplate(session); + ReactiveCassandraOperations template = new ReactiveCassandraTemplate(new DefaultBridgedReactiveSession(session)); Mono jonDoe = template.insert(newPerson("Jon Doe", 40));