Skip to content

Instantly share code, notes, and snippets.

@deque-blog
Created July 25, 2018 15:25
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save deque-blog/4bd8ca9357b62feb3d2dee110e818be8 to your computer and use it in GitHub Desktop.
Save deque-blog/4bd8ca9357b62feb3d2dee110e818be8 to your computer and use it in GitHub Desktop.
private void pollSweeperTable(Session session) {
List<Message> unsentMessages = messageRepository.fetchUnsentMessages();
for (Message message : unsentMessages)
sendMessage(session, message);
messageRepository.markSent(unsentMessages);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment