DATACASS-527 - Fix reactive CassandraTemplate example.

This commit is contained in:
Mark Paluch
2018-02-22 08:17:11 +01:00
parent 819789086b
commit 4958333bd0

View File

@@ -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<Person> jonDoe = template.insert(newPerson("Jon Doe", 40));