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