File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
src/main/java/com/rabbitmq/client Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -1134,7 +1134,9 @@ public int getChannelRpcTimeout() {
11341134 }
11351135
11361136 /**
1137- * Set whether or not channels check the reply type of an RPC call.
1137+ * When set to true, channels will check the response type (e.g. queue.declare
1138+ * expects a queue.declare-ok response) of RPC calls
1139+ * and ignore those that do not match.
11381140 * Default is false.
11391141 * @param channelShouldCheckRpcResponseType
11401142 */
Original file line number Diff line number Diff line change @@ -161,7 +161,7 @@ public void handleCompleteInboundCommand(AMQCommand command) throws IOException
161161 // waiting RPC continuation.
162162 if (!processAsync (command )) {
163163 // The filter decided not to handle/consume the command,
164- // so it must be some reply to an earlier RPC.
164+ // so it must be a response to an earlier RPC.
165165 if (_checkRpcResponseType ) {
166166 synchronized (_channelMutex ) {
167167 // check if this reply command is intended for the current waiting request before calling nextOutstandingRpc()
You can’t perform that action at this time.
0 commit comments