Что вы использовали в качестве поллера для Outbox?

В качестве поллера для Outbox часто используют периодический таймер или планировщик задач, который с определённым интервалом опрашивает таблицу Outbox в базе данных на предмет новых сообщений. Например, в embedded-системах или IoT-устройствах можно использовать простой цикл с задержкой, который читает новые записи и отправляет их в целевую систему.

Пример на псевдокоде:

while (true) {
    List<OutboxMessage> messages = outboxRepository.fetchNewMessages();
    for (OutboxMessage msg : messages) {
        sendMessage(msg);
        outboxRepository.markAsSent(msg);
    }
    Thread.sleep(pollIntervalMillis);
}

Такой подход прост и надёжен, особенно если нет необходимости в сложных системах событий или очередях. В более сложных системах можно использовать триггеры базы данных или механизмы уведомлений, но для embedded/IoT часто достаточно простого поллинга.