Fixed notify() -> notifyAll()

Rob Harrop · Rob Harrop · commit 0a98bd83935f · 2011-07-15T16:02:05.000+01:00
diff --git a/src/com/rabbitmq/client/impl/ChannelN.java b/src/com/rabbitmq/client/impl/ChannelN.java
@@ -242,7 +242,7 @@ public void broadcastShutdownSignal(ShutdownSignalException signal) {
         super.processShutdownSignal(signal, ignoreClosed, notifyRpc);
         broadcastShutdownSignal(signal);
         synchronized (unconfirmedSet) {
-            unconfirmedSet.notify();
+            unconfirmedSet.notifyAll();
         }
     }
 
@@ -1028,7 +1028,7 @@ protected void handleAckNack(long seqNo, boolean multiple, boolean nack) {
         synchronized (unconfirmedSet) {
             onlyAcksReceived = onlyAcksReceived && !nack;
             if (unconfirmedSet.isEmpty())
-                unconfirmedSet.notify();
+                unconfirmedSet.notifyAll();
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -242,7 +242,7 @@ public void broadcastShutdownSignal(ShutdownSignalException signal) {`
`242`	`242`	`super.processShutdownSignal(signal, ignoreClosed, notifyRpc);`
`243`	`243`	`broadcastShutdownSignal(signal);`
`244`	`244`	`synchronized (unconfirmedSet) {`
`245`		`- unconfirmedSet.notify();`
	`245`	`+ unconfirmedSet.notifyAll();`
`246`	`246`	`}`
`247`	`247`	`}`
`248`	`248`
`@@ -1028,7 +1028,7 @@ protected void handleAckNack(long seqNo, boolean multiple, boolean nack) {`
`1028`	`1028`	`synchronized (unconfirmedSet) {`
`1029`	`1029`	`onlyAcksReceived = onlyAcksReceived && !nack;`
`1030`	`1030`	`if (unconfirmedSet.isEmpty())`
`1031`		`- unconfirmedSet.notify();`
	`1031`	`+ unconfirmedSet.notifyAll();`
`1032`	`1032`	`}`
`1033`	`1033`	`}`
`1034`	`1034`	`}`