Be careful of potential livelock here

Author: Rob Harrop

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

@@ -162,12 +162,13 @@ public ConfirmListener getConfirmListener() {
     public boolean waitForConfirms()
         throws InterruptedException
     {
+        long seqHead = this.getNextPublishSeqNo();
         synchronized (unconfirmedSet) {
             while (true) {
                 if (getCloseReason() != null) {
                     throw Utility.fixStackTrace(getCloseReason());
                 }
-                if (unconfirmedSet.isEmpty()) {
+                if (unconfirmedSet.headSet(seqHead).isEmpty()) {
                     boolean aux = onlyAcksReceived;
                     onlyAcksReceived = true;
                     return aux;