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