diff --git a/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java b/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java index 729273241..6ad73ba98 100644 --- a/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java +++ b/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java @@ -190,5 +190,9 @@ public class WebSocketConnection implements DispatchChannel { sendMessage(builder.build(), Optional.of(message.getId()), !iterator.hasNext() && messages.hasMore()); } + + if (!messages.hasMore()) { + client.sendRequest("PUT", "/api/v1/queue/empty", null, Optional.absent()); + } } }