We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f599f8f commit 3958bb0Copy full SHA for 3958bb0
1 file changed
src/main/java/com/rabbitmq/client/impl/ChannelN.java
@@ -635,8 +635,8 @@ public AMQCommand transformReply(AMQCommand command) {
635
// we wait for the reply. We ignore the result.
636
// (It's NOT always close-ok.)
637
notify = true;
638
- // do not wait indefinitely
639
- k.getReply(10000);
+ int closeTimeout = _rpcTimeout == NO_RPC_TIMEOUT ? 10000 : _rpcTimeout;
+ k.getReply(closeTimeout);
640
} catch (TimeoutException ise) {
641
if (!abort)
642
throw ise;
0 commit comments