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

@@ -1,107 +0,0 @@
-package se.citerus.dddsample.application.impl;
-
-import org.apache.commons.lang.Validate;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.transaction.annotation.Transactional;
-import se.citerus.dddsample.application.BookingService;
-import se.citerus.dddsample.application.CargoLockingService;
-import se.citerus.dddsample.application.CargoLockingServiceInMem;
-import se.citerus.dddsample.domain.model.cargo.*;
-import se.citerus.dddsample.domain.model.location.Location;
-import se.citerus.dddsample.domain.model.location.LocationRepository;
-import se.citerus.dddsample.domain.model.location.UnLocode;
-import se.citerus.dddsample.domain.service.RoutingService;
-
-import java.util.Collections;
-import java.util.Date;
-import java.util.List;
-
-public final class BookingServiceImpl implements BookingService {
-
-  private final RoutingService routingService;
-  private final CargoFactory cargoFactory;
-  private final CargoRepository cargoRepository;
-  private final LocationRepository locationRepository;
-  private final CargoLockingService cargoLockingService;
-  private final Log logger = LogFactory.getLog(getClass());
-
-  public BookingServiceImpl(final RoutingService routingService,
-                            final CargoFactory cargoFactory,
-                            final CargoRepository cargoRepository,
-                            final LocationRepository locationRepository) {
-    this.routingService = routingService;
-    this.cargoFactory = cargoFactory;
-    this.cargoRepository = cargoRepository;
-    this.locationRepository = locationRepository;
-    this.cargoLockingService = new CargoLockingServiceInMem();
-  }
-
-  @Override
-  @Transactional
-  public TrackingId bookNewCargo(final UnLocode originUnLocode,
-                                 final UnLocode destinationUnLocode,
-                                 final Date arrivalDeadline) {
-    final Cargo cargo = cargoFactory.newCargo(originUnLocode, destinationUnLocode, arrivalDeadline);
-    cargoRepository.store(cargo);
-    logger.info("Booked new cargo with tracking id " + cargo.trackingId().stringValue());
-
-    return cargo.trackingId();
-  }
-
-  @Override
-  @Transactional(readOnly = true)
-  public List<Itinerary> requestPossibleRoutesForCargo(final TrackingId trackingId) {
-    final Cargo cargo = cargoRepository.find(trackingId);
-
-    if (cargo == null) {
-      return Collections.emptyList();
-    }
-
-    return routingService.fetchRoutesForSpecification(cargo.routeSpecification());
-  }
-
-  @Override
-  @Transactional
-  public void assignCargoToRoute(final Itinerary itinerary, final TrackingId trackingId) {
-    cargoLockingService.assertLocked(trackingId);
-
-    final Cargo cargo = cargoRepository.find(trackingId);
-    Validate.notNull(cargo, "Can't assign itinerary to non-existing cargo " + trackingId);
-    cargo.assignToRoute(itinerary);
-    cargoRepository.store(cargo);
-
-    logger.info("Assigned cargo " + trackingId + " to new route");
-
-    cargoLockingService.unlock(trackingId);
-  }
-
-  @Override
-  @Transactional
-  public void changeDestination(final TrackingId trackingId, final UnLocode unLocode) {
-    cargoLockingService.assertLocked(trackingId);
-
-    final Cargo cargo = cargoRepository.find(trackingId);
-    Validate.notNull(cargo, "Can't change destination of non-existing cargo " + trackingId);
-    final Location newDestination = locationRepository.find(unLocode);
-
-    final RouteSpecification routeSpecification = cargo.routeSpecification().withDestination(newDestination);
-    cargo.specifyNewRoute(routeSpecification);
-
-    cargoRepository.store(cargo);
-    logger.info("Changed destination for cargo " + trackingId + " to " + routeSpecification.destination());
-
-    cargoLockingService.unlock(trackingId);
-  }
-
-  @Override
-  @Transactional(readOnly = true)
-  public Cargo loadCargoForRouting(final TrackingId trackingId) {
-    final Cargo cargo = cargoRepository.find(trackingId);
-    if (cargo != null) {
-      cargoLockingService.lock(trackingId);
-    }
-    return cargo;
-  }
-
-}

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

@@ -1,61 +0,0 @@
-package se.citerus.dddsample.application.impl;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.transaction.annotation.Transactional;
-import se.citerus.dddsample.application.HandlingEventService;
-import se.citerus.dddsample.application.event.SystemEvents;
-import se.citerus.dddsample.domain.model.cargo.TrackingId;
-import se.citerus.dddsample.domain.model.handling.CannotCreateHandlingEventException;
-import se.citerus.dddsample.domain.model.handling.HandlingEvent;
-import se.citerus.dddsample.domain.model.handling.HandlingEventFactory;
-import se.citerus.dddsample.domain.model.handling.HandlingEventRepository;
-import se.citerus.dddsample.domain.model.location.UnLocode;
-import se.citerus.dddsample.domain.model.voyage.VoyageNumber;
-
-import java.util.Date;
-
-public final class HandlingEventServiceImpl implements HandlingEventService {
-
-  private final SystemEvents systemEvents;
-  private final HandlingEventRepository handlingEventRepository;
-  private final HandlingEventFactory handlingEventFactory;
-  private final Log logger = LogFactory.getLog(HandlingEventServiceImpl.class);
-
-  public HandlingEventServiceImpl(final HandlingEventRepository handlingEventRepository,
-                                  final SystemEvents systemEvents,
-                                  final HandlingEventFactory handlingEventFactory) {
-    this.handlingEventRepository = handlingEventRepository;
-    this.systemEvents = systemEvents;
-    this.handlingEventFactory = handlingEventFactory;
-  }
-
-  @Override
-  @Transactional(rollbackFor = CannotCreateHandlingEventException.class)
-  public void registerHandlingEvent(final Date completionTime,
-                                    final TrackingId trackingId,
-                                    final VoyageNumber voyageNumber,
-                                    final UnLocode unLocode,
-                                    final HandlingEvent.Type type) throws CannotCreateHandlingEventException {
-
-    final Date registrationTime = new Date();
-    /* Using a factory to create a HandlingEvent (aggregate). This is where
-       it is determined wether the incoming data, the attempt, actually is capable
-       of representing a real handling event. */
-    final HandlingEvent event = handlingEventFactory.createHandlingEvent(
-      registrationTime, completionTime, trackingId, voyageNumber, unLocode, type
-    );
-
-    /* Store the new handling event, which updates the persistent
-       state of the handling event aggregate (but not the cargo aggregate -
-       that happens asynchronously!)
-     */
-    handlingEventRepository.store(event);
-
-    /* Publish an event stating that a cargo has been handled. */
-    systemEvents.notifyOfHandlingEvent(event);
-
-    logger.info("Registered handling event");
-  }
-
-}

dddsample/src/main/java/se/citerus/dddsample/application/impl/package.html

@@ -1,7 +0,0 @@
-<html>
-<body>
-<p>
-	Implementation of the application layer.
-</p>
-</body>
-</html>