Как я могу с помощью Axon повторно инициализировать некоторое значение с той же первой командой InitAvailableQuantityCommand?

Предположим, у нас есть запас. этот запас должен сохранять идентификатор продукта и доступное количество. пользователь этого запаса может часто обновлять (InitAvailableQuantityCommand) доступное количество. если какой-то продукт был продан, наша система получит событие soldEvent (DecreaseAvailableQuantityCommand), и доступное количество проданного продукта должно быть уменьшено.

он хорошо работает с приведенным ниже агрегатом, пока, если я снова не попытаюсь повторно инициализировать запас с помощью InitAvailableQuantityCommand, событие будет проигнорировано и возникнет ошибка

Событие для агрегата [3333] в последовательности [0] уже было вставлено"

То, что я пытаюсь достичь, следующее:

1. InitAvailableQuantityCommand (productId = 1, количество = 10)
2. DecreaseAvailableQuantityCommand (productId = 1, количество = 1)
3. DecreaseAvailableQuantityCommand (productId = 1, количество = 1)
4. теперь у нас есть еще 8 доступных продуктов.
5. и в этот момент пользователь повторно инициализирует запас с 20 доступными продуктами для productId 1. пользователь отправит новую команду InitAvailableQuantityCommand (productId = 1, количество = 20), и в этот момент она не работает и не работает.

Что я не так?

спасибо.

@NoArgsConstructor
@Aggregate
@Data
public class AvailableQuantityAggregate {

private String partnerId;
private String productId;

@AggregateIdentifier
private String productVariationId;
private int quantity;

@CommandHandler
public AvailableQuantityAggregate(InitAvailableQuantityCommand cmd) {
    final ApplyMore apply = AggregateLifecycle.apply(AvailableQuantityInitializedEvent.builder()
                                                             .partnerId(cmd.getPartnerId())
                                                             .productId(cmd.getProductId())
                                                             .productVariationId(cmd.getProductVariationId())
                                                             .quantity(cmd.getQuantity())
                                                             .build());
}

@CommandHandler
public void handle(DecreaseAvailableQuantityCommand cmd) {
    AggregateLifecycle.apply(AvailableQuantityDecreasedEvent.builder()
                                     .productVariationId(cmd.getProductVariationId())
                                     .quantity(cmd.getQuantity())
                                     .build());
}

@EventSourcingHandler
protected void on(AvailableQuantityInitializedEvent event) {
    this.productVariationId = event.getProductVariationId();
    this.partnerId = event.getPartnerId();
    this.productId = event.getProductId();
    this.quantity = event.getQuantity();
}

@EventSourcingHandler
protected void on(AvailableQuantityDecreasedEvent event) {
    this.quantity = this.quantity-event.getQuantity();
}
}