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

GH-1600 Java 11 compatibility fixes

Browse Source 
Added explicit dependency declarations for missing javax.* packages
Fixed compile errors in affected classes

Resolves #1600
This commit is contained in:
Oleg Zhurakousky
2019-06-05 16:48:30 +02:00
parent db817b850d
commit bb1a94bfe8
2 changed files with 18 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-reactive/src/test/java/org/springframework/cloud/stream/reactive/StreamEmitterBasicTests.java
View File

@@ -21,6 +21,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Supplier;
import org.junit.Test;
import org.reactivestreams.Publisher;
@@ -230,8 +231,9 @@ public class StreamEmitterBasicTests {
@Bean
public Publisher<Message<String>> emit() {
AtomicInteger atomicInteger = new AtomicInteger();
return IntegrationFlows
.from(() -> new GenericMessage<>(
.from((Supplier<?>) () -> new GenericMessage<>(
"Hello World!!" + atomicInteger.getAndIncrement()),
e -> e.poller(p -> p.fixedDelay(1)))
.<String, String>transform(String::toUpperCase).toReactivePublisher();