| 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