Renamed ApplicationEvents to SystemEvents, a term used in DDD litterature.

dddsample/src/main/java/se/citerus/dddsample/application/event/CargoUpdater.java

@@ -12,15 +12,15 @@ import se.citerus.dddsample.domain.model.shared.HandlingActivity;
 
 public class CargoUpdater {
 
-  private ApplicationEvents applicationEvents;
+  private SystemEvents systemEvents;
   private CargoRepository cargoRepository;
   private HandlingEventRepository handlingEventRepository;
   private final Log logger = LogFactory.getLog(getClass());
 
-  public CargoUpdater(final ApplicationEvents applicationEvents,
+  public CargoUpdater(final SystemEvents systemEvents,
                       final CargoRepository cargoRepository,
                       final HandlingEventRepository handlingEventRepository) {
-    this.applicationEvents = applicationEvents;
+    this.systemEvents = systemEvents;
     this.cargoRepository = cargoRepository;
     this.handlingEventRepository = handlingEventRepository;
   }
@@ -49,7 +49,7 @@ public class CargoUpdater {
     */
 
     cargoRepository.store(cargo);
-    applicationEvents.notifyOfCargoUpdate(cargo);
+    systemEvents.notifyOfCargoUpdate(cargo);
     logger.info("Updated delivery of cargo " + cargo);
   }
 

dddsample/src/main/java/se/citerus/dddsample/application/event/ApplicationEvents.java → dddsample/src/main/java/se/citerus/dddsample/application/event/SystemEvents.java

@@ -10,7 +10,7 @@ import se.citerus.dddsample.domain.model.handling.HandlingEvent;
  * It may be implemented synchronously or asynchronously, using
  * for example JMS.
  */
-public interface ApplicationEvents {
+public interface SystemEvents {
 
   /**
    * A cargo has been handled.

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

@@ -4,7 +4,7 @@ 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.ApplicationEvents;
+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;
@@ -17,16 +17,16 @@ import java.util.Date;
 
 public final class HandlingEventServiceImpl implements HandlingEventService {
 
-  private final ApplicationEvents applicationEvents;
+  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 ApplicationEvents applicationEvents,
+                                  final SystemEvents systemEvents,
                                   final HandlingEventFactory handlingEventFactory) {
     this.handlingEventRepository = handlingEventRepository;
-    this.applicationEvents = applicationEvents;
+    this.systemEvents = systemEvents;
     this.handlingEventFactory = handlingEventFactory;
   }
 
@@ -53,7 +53,7 @@ public final class HandlingEventServiceImpl implements HandlingEventService {
     handlingEventRepository.store(event);
 
     /* Publish an event stating that a cargo has been handled. */
-    applicationEvents.notifyOfHandlingEvent(event);
+    systemEvents.notifyOfHandlingEvent(event);
 
     logger.info("Registered handling event");
   }

dddsample/src/main/java/se/citerus/dddsample/infrastructure/messaging/jms/JmsApplicationEventsImpl.java → dddsample/src/main/java/se/citerus/dddsample/infrastructure/messaging/jms/JmsSystemEventsImpl.java

@@ -2,7 +2,7 @@ package se.citerus.dddsample.infrastructure.messaging.jms;
 
 import org.springframework.jms.core.JmsOperations;
 import org.springframework.jms.core.MessageCreator;
-import se.citerus.dddsample.application.event.ApplicationEvents;
+import se.citerus.dddsample.application.event.SystemEvents;
 import se.citerus.dddsample.domain.model.cargo.Cargo;
 import se.citerus.dddsample.domain.model.handling.HandlingEvent;
 
@@ -14,7 +14,7 @@ import javax.jms.Session;
 /**
  * JMS based implementation.
  */
-public final class JmsApplicationEventsImpl implements ApplicationEvents {
+public final class JmsSystemEventsImpl implements SystemEvents {
 
   private JmsOperations jmsOperations;
   private Destination cargoHandledDestination;

dddsample/src/main/resources/context-infrastructure-messaging.xml

@@ -26,7 +26,7 @@
     <property name="connectionFactory" ref="jmsConnectionFactory"/>
   </bean>
 
-  <bean id="applicationEvents" class="se.citerus.dddsample.infrastructure.messaging.jms.JmsApplicationEventsImpl">
+  <bean id="applicationEvents" class="se.citerus.dddsample.infrastructure.messaging.jms.JmsSystemEventsImpl">
     <property name="jmsOperations" ref="jmsOperations"/>
     <property name="cargoHandledDestination" ref="cargoHandledQueue"/>
     <property name="cargoUpdateDestination" ref="cargoUpdateTopic"/>

dddsample/src/test/java/se/citerus/dddsample/application/HandlingEventServiceTest.java

@@ -2,7 +2,7 @@ package se.citerus.dddsample.application;
 
 import junit.framework.TestCase;
 import static org.easymock.EasyMock.*;
-import se.citerus.dddsample.application.event.ApplicationEvents;
+import se.citerus.dddsample.application.event.SystemEvents;
 import se.citerus.dddsample.application.impl.HandlingEventServiceImpl;
 import se.citerus.dddsample.domain.model.cargo.Cargo;
 import se.citerus.dddsample.domain.model.cargo.CargoRepository;
@@ -20,7 +20,7 @@ import java.util.Date;
 
 public class HandlingEventServiceTest extends TestCase {
   private HandlingEventServiceImpl service;
-  private ApplicationEvents applicationEvents;
+  private SystemEvents systemEvents;
   private CargoRepository cargoRepository;
   private VoyageRepository voyageRepository;
   private HandlingEventRepository handlingEventRepository;
@@ -33,14 +33,14 @@ public class HandlingEventServiceTest extends TestCase {
     voyageRepository = createMock(VoyageRepository.class);
     handlingEventRepository = createMock(HandlingEventRepository.class);
     locationRepository = createMock(LocationRepository.class);
-    applicationEvents = createMock(ApplicationEvents.class);
+    systemEvents = createMock(SystemEvents.class);
 
     HandlingEventFactory handlingEventFactory = new HandlingEventFactory(cargoRepository, voyageRepository, locationRepository);
-    service = new HandlingEventServiceImpl(handlingEventRepository, applicationEvents, handlingEventFactory);
+    service = new HandlingEventServiceImpl(handlingEventRepository, systemEvents, handlingEventFactory);
   }
 
   protected void tearDown() throws Exception {
-    verify(cargoRepository, voyageRepository, handlingEventRepository, applicationEvents);
+    verify(cargoRepository, voyageRepository, handlingEventRepository, systemEvents);
   }
 
   public void testRegisterEvent() throws Exception {
@@ -48,9 +48,9 @@ public class HandlingEventServiceTest extends TestCase {
     expect(voyageRepository.find(CM001.voyageNumber())).andReturn(CM001);
     expect(locationRepository.find(STOCKHOLM.unLocode())).andReturn(STOCKHOLM);
     handlingEventRepository.store(isA(HandlingEvent.class));
-    applicationEvents.notifyOfHandlingEvent(isA(HandlingEvent.class));
+    systemEvents.notifyOfHandlingEvent(isA(HandlingEvent.class));
 
-    replay(cargoRepository, voyageRepository, handlingEventRepository, locationRepository, applicationEvents);
+    replay(cargoRepository, voyageRepository, handlingEventRepository, locationRepository, systemEvents);
 
     service.registerHandlingEvent(new Date(), cargo.trackingId(), CM001.voyageNumber(), STOCKHOLM.unLocode(), HandlingEvent.Type.LOAD);
   }