We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4779b22 commit fc706ebCopy full SHA for fc706eb
src/com/rabbitmq/client/impl/AMQChannel.java
@@ -153,15 +153,15 @@ public void handleCompleteInboundCommand(AMQCommand command) throws IOException
153
public void enqueueRpc(RpcContinuation k)
154
{
155
synchronized (_channelMutex) {
156
- boolean wasInterrupted = false;
+ boolean waitClearedInterruptStatus = false;
157
while (_activeRpc != null) {
158
try {
159
_channelMutex.wait();
160
} catch (InterruptedException e) {
161
- wasInterrupted = true;
+ waitClearedInterruptStatus = true;
162
}
163
164
- if (wasInterrupted) {
+ if (waitClearedInterruptStatus) {
165
Thread.currentThread().interrupt();
166
167
_activeRpc = k;
0 commit comments