File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
src/main/java/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -165,7 +165,7 @@ public void handleCompleteInboundCommand(AMQCommand command) throws IOException
165165 if (_checkRpcResponseType ) {
166166 synchronized (_channelMutex ) {
167167 // check if this reply command is intended for the current waiting request before calling nextOutstandingRpc()
168- if (!_activeRpc .canHandleReply (command )) {
168+ if (_activeRpc != null && !_activeRpc .canHandleReply (command )) {
169169 // this reply command is not intended for the current waiting request
170170 // most likely a previous request timed out and this command is the reply for that.
171171 // Throw this reply command away so we don't stop the current request from waiting for its reply
You can’t perform that action at this time.
0 commit comments