Расскажи, как реализовывали паттерн Outbox…

Паттерн Outbox Transaction используется для обеспечения атомарности записи бизнес-данных и сообщений событий в рамках одной транзакции базы данных, что помогает избежать проблем с согласованностью при интеграции через события.

Реализация обычно включает следующие шаги:

В рамках одной транзакции сохраняется основная бизнес-сущность и одновременно в отдельную таблицу "outbox" записывается событие (например, в формате JSON), которое нужно отправить во внешнюю систему.
После успешного коммита транзакции отдельный процесс (например, отдельный сервис или поток) периодически читает из таблицы outbox новые события и отправляет их в очередь сообщений (Kafka, RabbitMQ и т.п.).
После успешной отправки событие помечается как обработанное или удаляется из таблицы.

Пример на Java с использованием Spring и JPA:

@Entity
public class OutboxEvent {
    @Id
    @GeneratedValue
    private Long id;
    private String aggregateType;
    private String aggregateId;
    private String type;
    private String payload; // JSON
    private boolean processed;
    // геттеры и сеттеры
}

@Transactional
public void saveOrderAndEvent(Order order, OutboxEvent event) {
    orderRepository.save(order);
    outboxEventRepository.save(event);
}

// Отдельный сервис для отправки событий
@Scheduled(fixedDelay = 5000)
public void publishEvents() {
    List<OutboxEvent> events = outboxEventRepository.findUnprocessed();
    for (OutboxEvent event : events) {
        messageBroker.send(event.getPayload());
        event.setProcessed(true);
        outboxEventRepository.save(event);
    }
}

Таким образом, достигается надежная доставка событий без риска рассинхронизации между базой и внешними системами.

Расскажи, как реализовывали паттерн Outbox Transaction.