Added loadCargoForRouting application service call, which will put a pessimistic lock on a cargo during (re-)routing in order to show benefits of aggregate separation explicitly. Not implemented yet though.

dddsample/src/main/java/se/citerus/dddsample/application/BookingService.java

@@ -1,5 +1,6 @@
 package se.citerus.dddsample.application;
 
+import se.citerus.dddsample.domain.model.cargo.Cargo;
 import se.citerus.dddsample.domain.model.cargo.Itinerary;
 import se.citerus.dddsample.domain.model.cargo.TrackingId;
 import se.citerus.dddsample.domain.model.location.UnLocode;
@@ -44,4 +45,13 @@ public interface BookingService {
    */
   void changeDestination(TrackingId trackingId, UnLocode unLocode);
 
+  /**
+   * Loads a cargo for (re-) routing.
+   * Locks the cargo for exclusive modification.
+   *
+   * @param trackingId tracking id
+   * @return The cargo.
+   */
+  Cargo loadCargoForRouting(TrackingId trackingId);
+
 }

dddsample/src/main/java/se/citerus/dddsample/application/impl/BookingServiceImpl.java

@@ -60,6 +60,7 @@ public final class BookingServiceImpl implements BookingService {
   @Override
   @Transactional
   public void assignCargoToRoute(final Itinerary itinerary, final TrackingId trackingId) {
+    // TODO locking semantics
     final Cargo cargo = cargoRepository.find(trackingId);
     Validate.notNull(cargo, "Can't assign itinerary to non-existing cargo " + trackingId);
     cargo.assignToRoute(itinerary);
@@ -71,6 +72,7 @@ public final class BookingServiceImpl implements BookingService {
   @Override
   @Transactional
   public void changeDestination(final TrackingId trackingId, final UnLocode unLocode) {
+    // TODO locking semantics
     final Cargo cargo = cargoRepository.find(trackingId);
     Validate.notNull(cargo, "Can't change destination of non-existing cargo " + trackingId);
     final Location newDestination = locationRepository.find(unLocode);
@@ -82,4 +84,12 @@ public final class BookingServiceImpl implements BookingService {
     logger.info("Changed destination for cargo " + trackingId + " to " + routeSpecification.destination());
   }
 
+  @Override
+  @Transactional
+  public Cargo loadCargoForRouting(TrackingId trackingId) {
+    // TODO locking semantics
+    final Cargo cargo = cargoRepository.find(trackingId);
+    return cargo;
+  }
+
 }

dddsample/src/main/java/se/citerus/dddsample/interfaces/booking/facade/internal/BookingServiceFacadeImpl.java

@@ -1,6 +1,5 @@
 package se.citerus.dddsample.interfaces.booking.facade.internal;
 
-import org.apache.log4j.Logger;
 import se.citerus.dddsample.application.BookingService;
 import se.citerus.dddsample.domain.model.cargo.Cargo;
 import se.citerus.dddsample.domain.model.cargo.CargoRepository;
@@ -36,7 +35,6 @@ public class BookingServiceFacadeImpl implements BookingServiceFacade {
   private LocationRepository locationRepository;
   private CargoRepository cargoRepository;
   private VoyageRepository voyageRepository;
-  private final Logger logger = Logger.getLogger(BookingServiceFacadeImpl.class);
 
   @Override
   public List<LocationDTO> listShippingLocations() {
@@ -57,7 +55,7 @@ public class BookingServiceFacadeImpl implements BookingServiceFacade {
 
   @Override
   public CargoRoutingDTO loadCargoForRouting(String trackingId) {
-    final Cargo cargo = cargoRepository.find(new TrackingId(trackingId));
+    final Cargo cargo = bookingService.loadCargoForRouting(new TrackingId(trackingId));
     final CargoRoutingDTOAssembler assembler = new CargoRoutingDTOAssembler();
     return assembler.toDTO(cargo);
   }