SpringCloud/spring-cloud-stream-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

More polish

Browse Source
This commit is contained in:
David Turanski
2020-12-11 12:38:43 -05:00
parent 400776aefd
commit bcc920d532
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java
View File

@@ -81,8 +81,8 @@ public class CouchbaseConsumerTests {
"couchbase.consumer.keyExpression=payload.email")
.run(context -> {
CouchbaseConsumerProperties properties = context.getBean(CouchbaseConsumerProperties.class);
Cluster cluster = context.getBean(Cluster.class);
String bucketName = properties.getBucketExpression().getValue(String.class);
Cluster cluster = context.getBean(Cluster.class);
Function<Flux<Message<?>>, Flux<MutationResult>> couchbaseConsumerFunction = context
.getBean("couchbaseConsumerFunction", Function.class);
StepVerifier.create(couchbaseConsumerFunction