@OnInitial / @OnUpdate / @OnTerminal

@OnInitial
void handle(Product product, JaversChangeContext<Product> ctx) {
    log.info("Created {} by {}", product.getName(),
        ctx.getCommitMetadata().getAuthor());
}

@OnTerminal
void handle(JaversChangeContext<Product> ctx) {
    log.info("Deleted entity {}", ctx.getEntityId());
}

@OnUpdate
void handle(Product product) {
    log.info("Updated: {}", product);
}

@JaversStream(entityType = Order.class)
@Checkpoint(saveEveryN = 1)
@RetryPolicy(maxAttempts = 3)
@DeadLetterQueue
public class OrderAuditHandler {

    @OnInitial
    void onCreated(Order order, JaversChangeContext<Order> ctx) {
        notificationService.sendNewOrderAlert(order);
    }

    @OnUpdate
    void onUpdated(Order order, JaversChangeContext<Order> ctx) {
        if (ctx.getChangedProperties().contains("status")) {
            notificationService.sendStatusChange(order, ctx.getVersion());
        }
    }

    @OnTerminal
    void onDeleted(JaversChangeContext<Order> ctx) {
        auditLog.recordDeletion(ctx.getEntityId(),
            ctx.getCommitMetadata().getAuthor());
    }
}