Skip to content

Commit 8bd9464

Browse files
committed
Use Overflow.BUFFER for PollableChPublisherAdapter
The `ReactiveStreamsConsumerTests.testReactiveStreamsConsumerPollableChannel()` fails periodically. Change the logic to rely on the `FluxSink.OverflowStrategy.BUFFER` for possible future subscribers, meanwhile with `IGNORE` we just lose a message altogether
1 parent 9b7b0d9 commit 8bd9464

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

spring-integration-core/src/main/java/org/springframework/integration/channel/MessageChannelReactiveUtils.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,8 +93,7 @@ public void subscribe(Subscriber<? super Message<T>> subscriber) {
9393
&& (m = this.channel.receive()) != null) { // NOSONAR
9494
sink.next((Message<T>) m);
9595
}
96-
}),
97-
FluxSink.OverflowStrategy.IGNORE)
96+
}))
9897
.subscribeOn(Schedulers.elastic())
9998
.subscribe(subscriber);
10099
}

0 commit comments

Comments
 (0)