Only one connection receive subscriber allowed.

Spring Boot 2.1.3 Greenwich SR1 Californium SR6 Netty 4.1.34

This seems to happen relatively easy when under load. Not sure what is going on here - it has been a while since I ran a test like this. I believe something similar has come up before but was fixed.

To reproduce take the repo here. I’ve setup a response server 8090, gateway 8080 and a gatling script.

I do not see the issue if I don’t go through the gateway.

java.lang.IllegalStateException: Only one connection receive subscriber allowed.
	at reactor.netty.channel.FluxReceive.startReceiver(FluxReceive.java:271) ~[reactor-netty-0.8.6.RELEASE.jar:0.8.6.RELEASE]
	at reactor.netty.channel.FluxReceive.lambda$subscribe$2(FluxReceive.java:124) ~[reactor-netty-0.8.6.RELEASE.jar:0.8.6.RELEASE]
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) ~[netty-common-4.1.34.Final.jar:4.1.34.Final]
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) ~[netty-common-4.1.34.Final.jar:4.1.34.Final]
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:495) ~[netty-transport-4.1.34.Final.jar:4.1.34.Final]
	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:905) ~[netty-common-4.1.34.Final.jar:4.1.34.Final]
	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_202]

Issue Analytics

State:
Created 4 years ago
Comments:6 (3 by maintainers)

Top GitHub Comments

1reaction

spencergibbcommented, Apr 9, 2019

@dave-fl going to review things in gateway soon with @rstoyanchev and @violetagg

0reactions

spencergibbcommented, May 6, 2019

@smaldini will that be included in Californium?

Top Results From Across the Web

Spring WebFlux: Only one connection receive subscriber ...

First of all .just is a cold operator, it allows as many as possible subscribers which receive the same data at any point...

Only one connection receive subscriber allowed when using ...

I do see that you have connection close Channel closed, now: 1 active connections, 4 inactive connections and 0 pending acquire requests.

Only one connection receive subscriber allowed-Springboot

The problem here is in fact that WebClient allows only one subscriber per connection. If you try to subscribe to the same exchanged...

reactor/reactor-netty - Gitter

Operators: : Operator called default onErrorDropped java.lang.IllegalStateException: Only one connection receive subscriber allowed. at reactor.netty.channel.

Spring webflux “Only one connection receive subscriber ...

The problem here is in fact that WebClient allows only one subscriber per connection. If you try to subscribe to the same exchanged...