From 400776aefdda11771e222c05e8055682d5181c25 Mon Sep 17 00:00:00 2001 From: David Turanski Date: Fri, 11 Dec 2020 12:09:27 -0500 Subject: [PATCH] Remove Java 11 APIs --- .../couchbase/consumer/CouchbaseConsumerTests.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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 2e41c79..4a5ab03 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 @@ -16,8 +16,8 @@ package io.spring.example.couchbase.consumer; +import java.util.Collections; import java.util.List; -import java.util.Map; import java.util.function.Consumer; import java.util.function.Function; @@ -163,11 +163,11 @@ public class CouchbaseConsumerTests { Cluster cluster = context.getBean(Cluster.class); String bucketName = "test"; MessageBuilder.withPayload(new User("David", "david@david.com")) - .copyHeaders(Map.of("bucketName", bucketName)).build(); + .copyHeaders(Collections.singletonMap("bucketName", bucketName)).build(); Function>, Flux> couchbaseConsumerFunction = context .getBean("couchbaseConsumerFunction", Function.class); Message message = MessageBuilder.withPayload(new User("David", "david@david.com")) - .copyHeaders(Map.of("bucketName", bucketName)).build(); + .copyHeaders(Collections.singletonMap("bucketName", bucketName)).build(); StepVerifier.create(couchbaseConsumerFunction.apply(Flux.just(message))) .expectNextMatches( (MutationResult mutationResult) -> mutationResult.mutationToken().get().bucketName() @@ -195,7 +195,8 @@ public class CouchbaseConsumerTests { .getBean("couchbaseConsumerFunction", Function.class); StepVerifier.create(couchbaseConsumerFunction .apply(Flux - .just(new GenericMessage<>(Map.of("user", new User("David", "david@david.com")))))) + .just(new GenericMessage<>( + Collections.singletonMap("user", new User("David", "david@david.com")))))) .expectNextMatches( mutationResult -> mutationResult.mutationToken().get().bucketName().equals( bucketName))