commit 9e4fcdea48f0d009985357c970014ddfba552be4
author mgeiss <mgeiss@mifos.org> Wed Sep 06 14:07:05 2017 +0200
committer mgeiss <mgeiss@mifos.org> Wed Sep 06 14:07:05 2017 +0200
tree 1cdc506da078af0f70f8ae2d0e350b815cb6bf5f
parent f7762906ebad39d9ff132a704b1b91e3d048365f

close product with commands

service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java

diff --git a/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java b/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java
index 3e51c69..788c4c4 100644
--- a/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java
+++ b/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java
@@ -109,7 +109,7 @@
   @CommandHandler
   @EventEmitter(selectorName = EventConstants.SELECTOR_NAME, selectorValue = EventConstants.POST_PRODUCT_DEFINITION_COMMAND)
   @Transactional
-  public String activateProductdefintion(final ActivateProductDefinitionCommand activateProductDefinitionCommand) {
+  public String activateProductDefinition(final ActivateProductDefinitionCommand activateProductDefinitionCommand) {
     final Optional<ProductDefinitionEntity> optionalProductDefinition = productDefinitionRepository.findByIdentifier(activateProductDefinitionCommand.identifier());
 
     if (optionalProductDefinition.isPresent()) {
@@ -137,7 +137,7 @@
   @CommandHandler
   @EventEmitter(selectorName = EventConstants.SELECTOR_NAME, selectorValue = EventConstants.POST_PRODUCT_DEFINITION_COMMAND)
   @Transactional
-  public String deactivateProductdefintion(final DeactivateProductDefinitionCommand activateProductDefinitionCommand) {
+  public String deactivateProductDefinition(final DeactivateProductDefinitionCommand activateProductDefinitionCommand) {
     final Optional<ProductDefinitionEntity> optionalProductDefinition = productDefinitionRepository.findByIdentifier(activateProductDefinitionCommand.identifier());
 
     if (optionalProductDefinition.isPresent()) {
@@ -207,6 +207,7 @@
       this.productDefinitionCommandRepository.delete(
           this.productDefinitionCommandRepository.findByProductDefinition(productDefinitionEntity)
       );
+      this.productDefinitionCommandRepository.flush();
 
       this.deleteDependingEntities(productDefinitionEntity);