Skip to content

Instantly share code, notes, and snippets.

@deque-blog

deque-blog/PollSweeperTable2.java

Created July 27, 2018 15:42
Show Gist options
  • Save deque-blog/2f0296be6e2f1f26b8120495bc560a34 to your computer and use it in GitHub Desktop.
Save deque-blog/2f0296be6e2f1f26b8120495bc560a34 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
PollSweeperTable2.java
private void pollSweeperTable(Session session) {
List<Message> unsentMessages = messageRepository.fetchUnsentMessages();
for (Message message : unsentMessages)
sendMessage(session, message);
messageRepository.markSent(unsentMessages); // One DB transaction
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment