Wrapping remote booking facade with Hibernate & RMI proxies, added more JMS queues and topics.

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

@@ -5,12 +5,11 @@
        xmlns:amq="http://activemq.apache.org/schema/core"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="
-        http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd
+        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/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+        http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
 
-
-  <amq:connectionFactory id="jmsConnectionFactory" brokerURL="vm://localhost?broker.persistent=false"/>
+  <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"/>
@@ -19,19 +18,18 @@
   <amq:queue id="rejectedRegistrationAttemptsQueue" name="RejectedRegistrationAttemptsQueue" physicalName="RejectedRegistrationAttemptsQueue"/>
 
   <jms:listener-container connection-factory="jmsConnectionFactory">
-    <jms:listener destination="cargoHandledTopic" ref="cargoHandledConsumer" />
-    <!-- TODO subscribers for these topics/queues
-    <jms:listener destination="misdirectedCargoTopic" ref="TODO"/>
-    <jms:listener destination="deliveredCargoTopic" ref="TODO"/>
-    -->
-    <jms:listener destination="handlingEventRegistrationAttemptQueue" ref="handlingEventRegistrationAttemptConsumer" />
+    <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="systemEvents" class="se.citerus.dddsample.infrastructure.messaging.jms.JmsSystemEventsImpl">
+  <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"/>
@@ -47,5 +45,7 @@
   <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"/>
   
 </beans>

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

@@ -15,27 +15,24 @@
   <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="registrationParser" ref="registrationParser"/>
+    <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="3000"/>
+    <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="registrationParser" ref="registrationParser"/>
-  </bean>
-
-  <bean id="registrationParser" class="se.citerus.dddsample.interfaces.handling.RegistrationParser">
-    <property name="systemEvents" ref="systemEvents"/>
+    <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">
@@ -45,8 +42,28 @@
     </property>
   </bean>
   
-  <!-- RMI exposed booking service facade -->
+  <!-- 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.BookingServiceFacadeImpl">
+    <property name="bookingService" ref="bookingService"/>
+    <property name="cargoRepository" ref="cargoRepository"/>
+    <property name="locationRepository" ref="locationRepository"/>
+    <property name="voyageRepository" ref="voyageRepository"/>
+  </bean>
+  
   <bean id="rmiBookingServiceFacade" class="org.springframework.remoting.rmi.RmiServiceExporter">
     <property name="serviceInterface" value="se.citerus.dddsample.interfaces.booking.facade.BookingServiceFacade"/>
     <property name="service" ref="bookingServiceFacade"/>

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

@@ -15,13 +15,13 @@
 
   <bean id="trackingService" class="se.citerus.dddsample.application.impl.TrackingServiceImpl">
     <constructor-arg ref="cargoRepository"/>
-    <constructor-arg ref="systemEvents"/>
+    <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="systemEvents"/>
+    <constructor-arg ref="applicationEvents"/>
   </bean>
 
   <bean id="handlingEventFactory" class="se.citerus.dddsample.domain.model.handling.HandlingEventFactory">
@@ -38,11 +38,4 @@
     <property name="graphTraversalService" ref="graphTraversalService"/>
   </bean>
 
-  <bean id="bookingServiceFacade" class="se.citerus.dddsample.interfaces.booking.facade.BookingServiceFacadeImpl">
-    <property name="bookingService" ref="bookingService"/>
-    <property name="cargoRepository" ref="cargoRepository"/>
-    <property name="locationRepository" ref="locationRepository"/>
-    <property name="voyageRepository" ref="voyageRepository"/>
-  </bean>
-  
 </beans>