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.
2 parents 7abddda + 6666ab0 commit 4a18f09Copy full SHA for 4a18f09
src/com/rabbitmq/client/impl/ChannelN.java
@@ -161,13 +161,12 @@ public void clearConfirmListeners() {
161
public boolean waitForConfirms()
162
throws InterruptedException
163
{
164
- long seqHead = this.getNextPublishSeqNo();
165
synchronized (unconfirmedSet) {
166
while (true) {
167
if (getCloseReason() != null) {
168
throw Utility.fixStackTrace(getCloseReason());
169
}
170
- if (unconfirmedSet.headSet(seqHead).isEmpty()) {
+ if (unconfirmedSet.isEmpty()) {
171
boolean aux = onlyAcksReceived;
172
onlyAcksReceived = true;
173
return aux;
0 commit comments