Fixes #114 - message handlers should not use @transactional

Author: cer

ftgo-consumer-service/src/main/java/net/chrisrichardson/ftgo/consumerservice/domain/ConsumerService.java

@@ -9,7 +9,6 @@
 
 import java.util.Optional;
 
-@Transactional
 public class ConsumerService {
 
   @Autowired
@@ -23,6 +22,7 @@ public void validateOrderForConsumer(long consumerId, Money orderTotal) {
     consumer.orElseThrow(ConsumerNotFoundException::new).validateOrderByConsumer(orderTotal);
   }
 
+  @Transactional
   public ResultWithEvents<Consumer> create(PersonName name) {
     ResultWithEvents<Consumer> rwe = Consumer.create(name);
     consumerRepository.save(rwe.result);

ftgo-order-service/src/main/java/net/chrisrichardson/ftgo/orderservice/domain/OrderService.java

@@ -25,7 +25,6 @@
 
 import static java.util.stream.Collectors.toList;
 
-@Transactional
 public class OrderService {
 
   private Logger logger = LoggerFactory.getLogger(getClass());
@@ -66,6 +65,7 @@ public OrderService(SagaInstanceFactory sagaInstanceFactory,
     this.meterRegistry = meterRegistry;
   }
 
+  @Transactional
   public Order createOrder(long consumerId, long restaurantId, DeliveryInformation deliveryInformation,
                            List<MenuItemIdAndQuantity> lineItems) {
     Restaurant restaurant = restaurantRepository.findById(restaurantId)
@@ -112,6 +112,7 @@ public void noteReversingAuthorization(Long orderId) {
     throw new UnsupportedOperationException();
   }
 
+  @Transactional
   public Order cancel(Long orderId) {
     Order order = orderRepository.findById(orderId)
             .orElseThrow(() -> new OrderNotFoundException(orderId));
@@ -149,6 +150,7 @@ public void confirmCancelled(long orderId) {
     updateOrder(orderId, Order::noteCancelled);
   }
 
+  @Transactional
   public Order reviseOrder(long orderId, OrderRevision orderRevision) {
     Order order = orderRepository.findById(orderId).orElseThrow(() -> new OrderNotFoundException(orderId));
     ReviseOrderSagaData sagaData = new ReviseOrderSagaData(order.getConsumerId(), orderId, null, orderRevision);
@@ -172,13 +174,11 @@ public void confirmRevision(long orderId, OrderRevision revision) {
     updateOrder(orderId, order -> order.confirmRevision(revision));
   }
 
-  @Transactional(propagation = Propagation.MANDATORY)
   public void createMenu(long id, String name, List<MenuItem> menuItems) {
     Restaurant restaurant = new Restaurant(id, name, menuItems);
     restaurantRepository.save(restaurant);
   }
 
-  @Transactional(propagation = Propagation.MANDATORY)
   public void reviseMenu(long id, List<MenuItem> menuItems) {
     restaurantRepository.findById(id).map(restaurant -> {
       List<OrderDomainEvent> events = restaurant.reviseMenu(menuItems);