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 @@ -182,7 +182,7 @@ public void handleCompleteInboundCommand(AMQCommand command) throws IOException
182182 if (_checkRpcResponseType ) {
183183 synchronized (_channelMutex ) {
184184 // check if this reply command is intended for the current waiting request before calling nextOutstandingRpc()
185- if (!_activeRpc .canHandleReply (command )) {
185+ if (_activeRpc != null && !_activeRpc .canHandleReply (command )) {
186186 // this reply command is not intended for the current waiting request
187187 // most likely a previous request timed out and this command is the reply for that.
188188 // 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