DATACASS-527 - Fix reactive CassandraTemplate example.

This commit is contained in:
Mark Paluch
2018-02-22 08:17:11 +01:00
parent 01d48e313c
commit 3869d939b8

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));