Commit 193b04d
committed
Do not wait before trying to dispatch a chunk of messages
A stream connection waited artificially before retrying to send a chunk
after Osiris returned an end_of_stream result. It was initially to let
some messages arrive in the stream.
This wait time does not seem necessary and can be even counter
productive. A connection with many consumers on the same stream that
gets published to can get many notifications from Osiris and ended up
waiting for each consumers. This can make the connection blocks for
several seconds and unable to perform other operations like simple RPC.
This commit removes the wait time.
References rabbitmq/rabbitmq-stream-java-client#8631 parent 3cc677b commit 193b04d
1 file changed
+0
-1
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
3706 | 3706 | | |
3707 | 3707 | | |
3708 | 3708 | | |
3709 | | - | |
3710 | 3709 | | |
3711 | 3710 | | |
3712 | 3711 | | |
| |||
0 commit comments