From bcc920d532398ecec8ac1eee427c40c59a54f156 Mon Sep 17 00:00:00 2001 From: David Turanski Date: Fri, 11 Dec 2020 12:38:43 -0500 Subject: [PATCH] More polish --- .../example/couchbase/consumer/CouchbaseConsumerTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java b/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java index 4a5ab03..18fb618 100644 --- a/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java +++ b/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java @@ -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> couchbaseConsumerFunction = context .getBean("couchbaseConsumerFunction", Function.class); StepVerifier.create(couchbaseConsumerFunction