File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed
src/main/java/com/rabbitmq/client/impl Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change 196
196
197
197
Currently, those test brokers will listen to the default
198
198
TCP ports of 5672 and 5673 for AMQP and 5671 and 5670
199
- for AMQP+TLS. Unforunately , this means no other standard
199
+ for AMQP+TLS. Unfortunately , this means no other standard
200
200
RabbitMQ can run on the same host at the same time.
201
201
-->
202
202
<execution >
Original file line number Diff line number Diff line change @@ -143,8 +143,12 @@ public void handleCompleteInboundCommand(AMQCommand command) throws IOException
143
143
if (!processAsync (command )) {
144
144
// The filter decided not to handle/consume the command,
145
145
// so it must be some reply to an earlier RPC.
146
- nextOutstandingRpc ().handleCommand (command );
147
- markRpcFinished ();
146
+ RpcContinuation nextOutstandingRpc = nextOutstandingRpc ();
147
+ // the outstanding RPC can be null when calling Channel#asyncRpc
148
+ if (nextOutstandingRpc != null ) {
149
+ nextOutstandingRpc .handleCommand (command );
150
+ markRpcFinished ();
151
+ }
148
152
}
149
153
}
150
154
You can’t perform that action at this time.
0 commit comments