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

Remove Java 11 APIs

Browse Source
This commit is contained in:
David Turanski
2020-12-11 12:09:27 -05:00
parent 7349be38e5
commit 400776aefd
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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<Message<?>>, Flux<MutationResult>> 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))