Send end of queue message after connection drain
// FREEBIE
This commit is contained in:
parent
6b84f54611
commit
f79a0a8603
|
@ -190,5 +190,9 @@ public class WebSocketConnection implements DispatchChannel {
|
||||||
|
|
||||||
sendMessage(builder.build(), Optional.of(message.getId()), !iterator.hasNext() && messages.hasMore());
|
sendMessage(builder.build(), Optional.of(message.getId()), !iterator.hasNext() && messages.hasMore());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (!messages.hasMore()) {
|
||||||
|
client.sendRequest("PUT", "/api/v1/queue/empty", null, Optional.<byte[]>absent());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue