Skip to content

Commit 4779b22

Browse files
author
Emile Joubert
committed
Merged bug24569 into default
2 parents a532507 + 8fb1b67 commit 4779b22

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/com/rabbitmq/client/impl/AMQChannel.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,13 +153,17 @@ public void handleCompleteInboundCommand(AMQCommand command) throws IOException
153153
public void enqueueRpc(RpcContinuation k)
154154
{
155155
synchronized (_channelMutex) {
156+
boolean wasInterrupted = false;
156157
while (_activeRpc != null) {
157158
try {
158159
_channelMutex.wait();
159160
} catch (InterruptedException e) {
160-
Thread.currentThread().interrupt();
161+
wasInterrupted = true;
161162
}
162163
}
164+
if (wasInterrupted) {
165+
Thread.currentThread().interrupt();
166+
}
163167
_activeRpc = k;
164168
}
165169
}

0 commit comments

Comments
 (0)