Restructured the context files to be organized per layer, and moved the external graph traversal application to its own, separate context. Communication is now through RMI.

dddsample/src/main/resources/context-application.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+
+  <bean id="bookingService" class="se.citerus.dddsample.application.impl.BookingServiceImpl">
+    <constructor-arg ref="cargoRepository"/>
+    <constructor-arg ref="locationRepository"/>
+    <constructor-arg ref="routingService"/>
+  </bean>
+
+  <bean id="trackingService" class="se.citerus.dddsample.application.impl.TrackingServiceImpl">
+    <constructor-arg ref="cargoRepository"/>
+    <constructor-arg ref="applicationEvents"/>
+  </bean>
+
+  <bean id="handlingEventService" class="se.citerus.dddsample.application.impl.HandlingEventServiceImpl">
+    <constructor-arg ref="handlingEventRepository"/>
+    <constructor-arg ref="handlingEventFactory"/>
+    <constructor-arg ref="applicationEvents"/>
+  </bean>
+
+</beans>

dddsample/src/main/resources/context-domain.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+
+  <bean id="handlingEventFactory" class="se.citerus.dddsample.domain.model.handling.HandlingEventFactory">
+    <constructor-arg ref="cargoRepository"/>
+    <constructor-arg ref="voyageRepository"/>
+    <constructor-arg ref="locationRepository"/>
+  </bean>
+
+</beans>

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

@@ -0,0 +1,115 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:jms="http://www.springframework.org/schema/jms"
+       xmlns:amq="http://activemq.apache.org/schema/core"
+       xmlns:tx="http://www.springframework.org/schema/tx"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xsi:schemaLocation="
+        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+        http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-2.5.xsd
+        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
+        http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
+
+  <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
+    <property name="location" value="classpath:jdbc.properties"/>
+  </bean>
+
+
+  <!-- JMS messaging -->
+
+  <amq:connectionFactory id="jmsConnectionFactory" brokerURL="vm://localhost?broker.persistent=false&amp;broker.useJmx=false"/>
+
+  <amq:topic id="cargoHandledTopic" name="CargoHandledTopic" physicalName="CargoHandledTopic"/>
+  <amq:topic id="misdirectedCargoTopic" name="MisdirectedCargoTopic" physicalName="MisdirectedCargoTopic"/>
+  <amq:topic id="deliveredCargoTopic" name="DeliveredCargoTopic" physicalName="DeliveredCargoTopic"/>
+  <amq:queue id="handlingEventRegistrationAttemptQueue" name="HandlingEventRegistrationAttemptQueue" physicalName="HandlingEventRegistrationAttemptQueue"/>
+  <amq:queue id="rejectedRegistrationAttemptsQueue" name="RejectedRegistrationAttemptsQueue" physicalName="RejectedRegistrationAttemptsQueue"/>
+
+  <jms:listener-container connection-factory="jmsConnectionFactory">
+    <jms:listener destination="CargoHandledTopic" ref="cargoHandledConsumer" />
+    <jms:listener destination="HandlingEventRegistrationAttemptQueue" ref="handlingEventRegistrationAttemptConsumer" />
+    <jms:listener destination="MisdirectedCargoTopic" ref="simpleLoggingConsumer"/>
+    <jms:listener destination="DeliveredCargoTopic" ref="simpleLoggingConsumer"/>
+    <jms:listener destination="RejectedRegistrationAttemptsQueue" ref="simpleLoggingConsumer"/>
+  </jms:listener-container>
+
+  <bean id="jmsOperations" class="org.springframework.jms.core.JmsTemplate">
+    <property name="connectionFactory" ref="jmsConnectionFactory"/>
+  </bean>
+
+  <bean id="applicationEvents" class="se.citerus.dddsample.infrastructure.messaging.jms.JmsApplicationEventsImpl">
+    <property name="jmsOperations" ref="jmsOperations"/>
+    <property name="cargoHandledTopic" ref="cargoHandledTopic"/>
+    <property name="misdirectedCargoTopic" ref="misdirectedCargoTopic"/>
+    <property name="deliveredCargoTopic" ref="deliveredCargoTopic"/>
+    <property name="rejectedRegistrationAttemptsQueue" ref="rejectedRegistrationAttemptsQueue"/>
+    <property name="handlingEventQueue" ref="handlingEventRegistrationAttemptQueue"/>
+  </bean>
+
+  <bean id="cargoHandledConsumer" class="se.citerus.dddsample.infrastructure.messaging.jms.CargoHandledConsumer">
+    <property name="trackingService" ref="trackingService"/>
+  </bean>
+
+  <bean id="handlingEventRegistrationAttemptConsumer" class="se.citerus.dddsample.infrastructure.messaging.jms.HandlingEventRegistrationAttemptConsumer">
+    <property name="handlingEventService" ref="handlingEventService"/>
+  </bean>
+
+  <bean id="simpleLoggingConsumer" class="se.citerus.dddsample.infrastructure.messaging.jms.SimpleLoggingConsumer"/>
+
+  
+  <!-- Persistence - database, Hibernate, repository implementations -->
+
+  
+  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
+    <property name="url" value="${hibernate.connection.url}"/>
+    <property name="driverClassName" value="${hibernate.connection.driver_class}"/>
+    <property name="username" value="${hibernate.connection.username}"/>
+    <property name="password" value="${hibernate.connection.password}"/>
+    <property name="initialSize" value="4"/>
+    <property name="defaultAutoCommit" value="false"/>
+  </bean>
+
+  <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
+    <property name="dataSource" ref="dataSource"/>
+    <property name="configLocation" value="classpath:hibernate.cfg.xml"/>
+  </bean>
+
+  <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+  <bean id="cargoRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.CargoRepositoryHibernate">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+  <bean id="handlingEventRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.HandlingEventRepositoryHibernate">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+  <bean id="voyageRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.VoyageRepositoryHibernate">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+  <bean id="locationRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.LocationRepositoryHibernate">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+  <tx:annotation-driven transaction-manager="transactionManager"/>
+
+
+  <!-- External graph traversal routing service  -->
+
+  <bean id="routingService" class="se.citerus.dddsample.infrastructure.routing.ExternalRoutingService">
+    <property name="graphTraversalService" ref="graphTraversalService"/>
+    <property name="locationRepository" ref="locationRepository"/>
+    <property name="voyageRepository" ref="voyageRepository"/>
+  </bean>
+
+  <bean id="graphTraversalService" class="org.springframework.remoting.rmi.RmiProxyFactoryBean">
+    <property name="serviceUrl" value="rmi://localhost:1099/PathFinder"/>
+    <property name="serviceInterface" value="com.partner.pathfinder.api.GraphTraversalService"/>
+    <property name="lookupStubOnStartup" value="false"/>
+  </bean>
+
+</beans>

dddsample/src/main/resources/context-interfaces.xml

@@ -0,0 +1,103 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	     xmlns:jaxws="http://cxf.apache.org/jaxws"
+       xsi:schemaLocation="http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd
+                           http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+
+  <import resource="classpath:META-INF/cxf/cxf.xml"/>
+  <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml"/>
+  <import resource="classpath:META-INF/cxf/cxf-servlet.xml"/>
+
+
+  <!-- Handling report web service -->
+
+
+  <jaxws:endpoint id="jax-ws.http" implementor="#handlingReportService" address="/ws/RegisterEvent"/>
+
+  <bean id="handlingReportService" class="se.citerus.dddsample.interfaces.handling.ws.impl.HandlingReportServiceImpl">
+    <property name="applicationEvents" ref="applicationEvents"/>
+  </bean>
+
+
+  <!-- File upload directory scanner -->
+
+
+  <bean id="scheduledTask" class="org.springframework.scheduling.timer.ScheduledTimerTask">
+    <property name="period" value="5000"/>
+    <property name="delay" value="5000"/>
+    <property name="timerTask" ref="uploadDirectoryScanner"/>
+  </bean>
+
+  <bean id="uploadDirectoryScanner" class="se.citerus.dddsample.interfaces.handling.file.UploadDirectoryScanner">
+    <property name="uploadDirectory" value="/tmp/upload"/>
+    <property name="parseFailureDirectory" value="/tmp/failed"/>
+    <property name="applicationEvents" ref="applicationEvents"/>
+  </bean>
+
+  <bean id="handlingReportConsumptionSupport" class="se.citerus.dddsample.interfaces.handling.HandlingReportParser"/>
+
+  <bean id="timerFactory" class="org.springframework.scheduling.timer.TimerFactoryBean">
+    <property name="scheduledTimerTasks">
+      <list>
+        <ref bean="scheduledTask"/>
+      </list>
+    </property>
+  </bean>
+
+
+  <!-- RMI exposed booking service facade, which operates in an open Hibernate session -->
+
+
+  <bean id="hibernateInterceptor" class="org.springframework.orm.hibernate3.HibernateInterceptor">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+  <bean id="bookingServiceFacade" class="org.springframework.aop.framework.ProxyFactoryBean">
+    <property name="target" ref="bookingServiceFacadeTarget"/>
+    <property name="interceptorNames">
+      <list>
+        <value>hibernateInterceptor</value>
+      </list>
+    </property>
+  </bean>
+
+  <bean id="bookingServiceFacadeTarget" class="se.citerus.dddsample.interfaces.booking.facade.internal.BookingServiceFacadeImpl">
+    <property name="bookingService" ref="bookingService"/>
+    <property name="cargoRepository" ref="cargoRepository"/>
+    <property name="locationRepository" ref="locationRepository"/>
+    <property name="voyageRepository" ref="voyageRepository"/>
+  </bean>
+  
+  <bean class="org.springframework.remoting.rmi.RmiServiceExporter">
+    <property name="serviceInterface" value="se.citerus.dddsample.interfaces.booking.facade.BookingServiceFacade"/>
+    <property name="service" ref="bookingServiceFacade"/>
+    <property name="serviceName" value="BookingService"/>
+  </bean>
+
+
+  <!-- Tracking web application support -->
+
+
+  <bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
+    <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
+    <property name="prefix" value="/WEB-INF/jsp/pub/"/>
+    <property name="suffix" value=".jsp"/>
+    <property name="requestContextAttribute" value="rc"/>
+    <property name="cache" value="false"/>
+  </bean>
+
+  <bean id="messageSource" class="org.springframework.context.support.ResourceBundleMessageSource">
+    <property name="basename" value="messages"/>
+  </bean>
+
+  <bean id="localeResolver" class="org.springframework.web.servlet.i18n.FixedLocaleResolver">
+    <property name="defaultLocale" value="en"/>
+  </bean>
+
+  <bean id="openSessionInViewInterceptor" class="org.springframework.orm.hibernate3.support.OpenSessionInViewInterceptor">
+    <property name="sessionFactory" ref="sessionFactory"/>
+  </bean>
+
+</beans>

dddsample/src/main/resources/context-persistence-hibernate.xml

@@ -1,44 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
-
-  <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
-    <property name="location" value="classpath:jdbc.properties"/>
-  </bean>
-
-  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
-    <property name="url" value="${hibernate.connection.url}"/>
-    <property name="driverClassName" value="${hibernate.connection.driver_class}"/>
-    <property name="username" value="${hibernate.connection.username}"/>
-    <property name="password" value="${hibernate.connection.password}"/>
-    <property name="initialSize" value="4"/>
-    <property name="defaultAutoCommit" value="false"/>
-  </bean>
-
-  <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
-    <property name="dataSource" ref="dataSource"/>
-    <property name="configLocation" value="classpath:hibernate.cfg.xml"/>
-  </bean>
-
-  <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
-    <property name="sessionFactory" ref="sessionFactory"/>
-  </bean>
-  
-  <bean id="cargoRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.CargoRepositoryHibernate">
-    <property name="sessionFactory" ref="sessionFactory"/>
-  </bean>
-
-  <bean id="handlingEventRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.HandlingEventRepositoryHibernate">
-    <property name="sessionFactory" ref="sessionFactory"/>
-  </bean>
-
-  <bean id="voyageRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.VoyageRepositoryHibernate">
-    <property name="sessionFactory" ref="sessionFactory"/>
-  </bean>
-
-  <bean id="locationRepository" class="se.citerus.dddsample.infrastructure.persistence.hibernate.LocationRepositoryHibernate">
-    <property name="sessionFactory" ref="sessionFactory"/>
-  </bean>
-</beans>

dddsample/src/main/resources/context-service.xml

@@ -1,41 +0,0 @@
-<?xml version="1.0"?>
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:tx="http://www.springframework.org/schema/tx"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="
-        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
-        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
-
-  <bean id="bookingService" class="se.citerus.dddsample.application.impl.BookingServiceImpl">
-    <constructor-arg ref="cargoRepository"/>
-    <constructor-arg ref="locationRepository"/>
-    <constructor-arg ref="routingService"/>
-  </bean>
-
-  <bean id="trackingService" class="se.citerus.dddsample.application.impl.TrackingServiceImpl">
-    <constructor-arg ref="cargoRepository"/>
-    <constructor-arg ref="applicationEvents"/>
-  </bean>
-
-  <bean id="handlingEventService" class="se.citerus.dddsample.application.impl.HandlingEventServiceImpl">
-    <constructor-arg ref="handlingEventRepository"/>
-    <constructor-arg ref="handlingEventFactory"/>
-    <constructor-arg ref="applicationEvents"/>
-  </bean>
-
-  <bean id="handlingEventFactory" class="se.citerus.dddsample.domain.model.handling.HandlingEventFactory">
-    <constructor-arg ref="cargoRepository"/>
-    <constructor-arg ref="voyageRepository"/>
-    <constructor-arg ref="locationRepository"/>
-  </bean>
-
-  <tx:annotation-driven transaction-manager="transactionManager"/>
-
-  <bean id="routingService" class="se.citerus.dddsample.infrastructure.routing.ExternalRoutingService">
-    <property name="locationRepository" ref="locationRepository"/>
-    <property name="voyageRepository" ref="voyageRepository"/>
-    <property name="graphTraversalService" ref="graphTraversalService"/>
-  </bean>
-
-</beans>

dddsample/src/main/resources/context-web.xml

@@ -1,41 +0,0 @@
-<?xml version="1.0"?>
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
-
-  <bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
-    <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
-    <property name="prefix" value="/WEB-INF/jsp/"/>
-    <property name="suffix" value=".jsp"/>
-    <property name="requestContextAttribute" value="rc"/>
-    <property name="cache" value="false"/>
-  </bean>
-
-  <!--
-    - This bean resolves specific types of exceptions to corresponding logical
-    - view names for error views. The default behaviour of DispatcherServlet
-    - is to propagate all exceptions to the servlet container: this will happen
-    - here with all other types of exceptions.
-  -->
-  <bean class="org.springframework.web.servlet.handler.SimpleMappingExceptionResolver">
-    <property name="exceptionMappings">
-      <props>
-        <prop key="org.springframework.dao.DataAccessException">error/dataAccessFailure</prop>
-      </props>
-    </property>
-  </bean>
-
-  <bean id="messageSource" class="org.springframework.context.support.ResourceBundleMessageSource">
-    <property name="basename" value="messages"/>
-  </bean>
-
-  <bean id="localeResolver" class="org.springframework.web.servlet.i18n.FixedLocaleResolver">
-    <property name="defaultLocale" value="en"/>
-  </bean>
-
-  <bean id="openSessionInViewInterceptor" class="org.springframework.orm.hibernate3.support.OpenSessionInViewInterceptor">
-    <property name="sessionFactory" ref="sessionFactory"/>  
-  </bean>
-
-</beans>