findPendingMessagesToProcess

@Query(value = "SELECT s FROM ScheduledMessage s WHERE s.status = 'PENDING' AND s.scheduledTo <= :now")
abstract fun findPendingMessagesToProcess(now: LocalDateTime): List<ScheduledMessage>(source)