Reporting application with a bounded context partialy implemented (server side REST API on top of separate data store)

dddsample/external/reporting/pom.xml

@@ -1,3 +1,4 @@
+
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
   <modelVersion>4.0.0</modelVersion>
@@ -11,8 +12,48 @@
   <packaging>war</packaging>
   <name>External: Reporting context</name>
   <version>${project.parent.version}</version>
-  <description>DESC</description>
-  <build>
-    <defaultGoal>package</defaultGoal>
-  </build>
+  <description>Reporting context</description>
+  <dependencies>
+    <dependency>
+      <groupId>org.springframework</groupId>
+      <artifactId>spring</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework</groupId>
+      <artifactId>spring-test</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>commons-dbcp</groupId>
+      <artifactId>commons-dbcp</artifactId>  
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.cxf</groupId>
+      <artifactId>cxf-rt-transports-http</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.cxf</groupId>
+      <artifactId>cxf-rt-transports-http-jetty</artifactId>
+      <version>2.2.2</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.cxf</groupId>
+      <artifactId>cxf-rt-frontend-jaxrs</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>javax.ws.rs</groupId>
+      <artifactId>jsr311-api</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>hsqldb</groupId>
+      <artifactId>hsqldb</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>cglib</groupId>
+      <artifactId>cglib-nodep</artifactId>
+    </dependency>
+  </dependencies>
 </project>

dddsample/external/reporting/src/main/java/com.reporting/CargoReport.java

@@ -0,0 +1,140 @@
+package com.reporting;
+
+import javax.xml.bind.annotation.XmlRootElement;
+import java.util.Date;
+import java.util.List;
+
+@XmlRootElement(name = "cargo")
+public class CargoReport {
+
+  String trackingId;
+  String receivedIn;
+  String finalDestination;
+  String arrivalDeadline;
+  String eta;
+  String currentStatus;
+  String currentVoyage;
+  String currentLocation;
+  String lastUpdatedOn;
+  List<Handling> handlings;
+
+  public String getTrackingId() {
+    return trackingId;
+  }
+
+  public void setTrackingId(String trackingId) {
+    this.trackingId = trackingId;
+  }
+
+  public String getReceivedIn() {
+    return receivedIn;
+  }
+
+  public void setReceivedIn(String receivedIn) {
+    this.receivedIn = receivedIn;
+  }
+
+  public String getFinalDestination() {
+    return finalDestination;
+  }
+
+  public void setFinalDestination(String finalDestination) {
+    this.finalDestination = finalDestination;
+  }
+
+  public String getArrivalDeadline() {
+    return arrivalDeadline;
+  }
+
+  public void setArrivalDeadline(String arrivalDeadline) {
+    this.arrivalDeadline = arrivalDeadline;
+  }
+
+  public String getEta() {
+    return eta;
+  }
+
+  public void setEta(String eta) {
+    this.eta = eta;
+  }
+
+  public String getCurrentStatus() {
+    return currentStatus;
+  }
+
+  public void setCurrentStatus(String currentStatus) {
+    this.currentStatus = currentStatus;
+  }
+
+  public String getCurrentVoyage() {
+    return currentVoyage;
+  }
+
+  public void setCurrentVoyage(String currentVoyage) {
+    this.currentVoyage = currentVoyage;
+  }
+
+  public String getCurrentLocation() {
+    return currentLocation;
+  }
+
+  public void setCurrentLocation(String currentLocation) {
+    this.currentLocation = currentLocation;
+  }
+
+  public List<Handling> getHandlings() {
+    return handlings;
+  }
+
+  public void setHandlings(List<Handling> handlings) {
+    this.handlings = handlings;
+  }
+
+  public String getLastUpdatedOn() {
+    return lastUpdatedOn;
+  }
+
+  public void setLastUpdatedOn(String lastUpdatedOn) {
+    this.lastUpdatedOn = lastUpdatedOn;
+  }
+
+  public static class Handling {
+    String type;
+    String location;
+    String voyage;
+    Date completedOn;
+
+    public String getType() {
+      return type;
+    }
+
+    public void setType(String type) {
+      this.type = type;
+    }
+
+    public String getLocation() {
+      return location;
+    }
+
+    public void setLocation(String location) {
+      this.location = location;
+    }
+
+    public String getVoyage() {
+      return voyage;
+    }
+
+    public void setVoyage(String voyage) {
+      this.voyage = voyage;
+    }
+
+    public Date getCompletedOn() {
+      return completedOn;
+    }
+
+    public void setCompletedOn(Date completedOn) {
+      this.completedOn = completedOn;
+    }
+  }
+
+}

dddsample/external/reporting/src/main/java/com.reporting/CargoReportRowMapper.java

@@ -0,0 +1,25 @@
+package com.reporting;
+
+import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+class CargoReportRowMapper implements ParameterizedRowMapper<CargoReport> {
+
+  @Override
+  public CargoReport mapRow(ResultSet rs, int rowNum) throws SQLException {
+    CargoReport cargoReport = new CargoReport();
+    cargoReport.setTrackingId(rs.getString("cargo_tracking_id"));
+    cargoReport.setArrivalDeadline(Constants.US_DATETIME.format(rs.getTimestamp("arrival_deadline")));
+    cargoReport.setCurrentLocation(rs.getString("current_location"));
+    cargoReport.setCurrentStatus(rs.getString("current_status"));
+    cargoReport.setCurrentVoyage(rs.getString("current_voyage_number"));
+    cargoReport.setEta(Constants.US_DATETIME.format(rs.getTimestamp("eta")));
+    cargoReport.setFinalDestination(rs.getString("destination"));
+    cargoReport.setLastUpdatedOn(Constants.US_DATETIME.format(rs.getTimestamp("last_updated_on")));
+    cargoReport.setReceivedIn(rs.getString("received_in"));
+    return cargoReport;
+  }
+
+}

dddsample/external/reporting/src/main/java/com.reporting/Constants.java

@@ -0,0 +1,10 @@
+package com.reporting;
+
+import java.text.DateFormat;
+import java.util.Locale;
+
+public interface Constants {
+
+  DateFormat US_DATETIME = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.SHORT, Locale.US);
+
+}

dddsample/external/reporting/src/main/java/com.reporting/DeliveryReport.java

@@ -1,4 +0,0 @@
-package com.reporting;
-
-public class DeliveryReport {
-}

dddsample/external/reporting/src/main/java/com.reporting/HandlingRowMapper.java

@@ -0,0 +1,20 @@
+package com.reporting;
+
+import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+class HandlingRowMapper implements ParameterizedRowMapper<CargoReport.Handling> {
+
+  @Override
+  public CargoReport.Handling mapRow(ResultSet rs, int rowNum) throws SQLException {
+    CargoReport.Handling handling = new CargoReport.Handling();
+    handling.setCompletedOn(rs.getDate("completed_on"));
+    handling.setLocation(rs.getString("location"));
+    handling.setType(rs.getString("type"));
+    handling.setVoyage(rs.getString("voyage_number"));
+    return handling;
+  }
+
+}

dddsample/external/reporting/src/main/java/com.reporting/ReportingService.java

@@ -1,9 +1,93 @@
 package com.reporting;
 
-public interface ReportingService {
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowCallbackHandler;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.dao.EmptyResultDataAccessException;
 
-  DeliveryReport getDeliveryReport(int start, int offset);
+import javax.sql.DataSource;
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.core.Context;
+import java.util.List;
+import java.util.ArrayList;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 
-  VoyageReport getVoyageReport();
+@Produces("application/json")
+@Path("/report")
+public class ReportingService {
 
+  private JdbcTemplate jdbc;
+  private HandlingRowMapper handlingRowMapper;
+  private CargoReportRowMapper cargoReportRowMapper;
+  private VoyageReportRowMapper rowMapper;
+
+  public ReportingService(DataSource dataSource) {
+    this.jdbc = new JdbcTemplate(dataSource);
+    this.handlingRowMapper = new HandlingRowMapper();
+    this.cargoReportRowMapper = new CargoReportRowMapper();
+    this.rowMapper = new VoyageReportRowMapper();
+  }
+
+  @GET
+  @Path("/cargo/{trackingId}")
+  @Transactional
+  public CargoReport getCargoReport(@PathParam("trackingId") String trackingId, @Context Response.ResponseBuilder response) {
+    CargoReport cargoReport = loadCargoReport(trackingId);
+    if (cargoReport == null) return null;
+
+    cargoReport.setHandlings(loadHandlings(trackingId));
+    //response.lastModified(cargoReport.getLastUpdatedOn());
+    return cargoReport;
+  }
+
+  @GET
+  @Path("/voyage/{voyageNumber}")
+  @Transactional
+  public VoyageReport getVoyageReport(@PathParam("voyageNumber") String voyageNumber, @Context Response.ResponseBuilder response) {
+    VoyageReport voyageReport = loadVoyageReport(voyageNumber);
+    if (voyageReport == null) return null;
+
+    //response.lastModified(voyageReport.getLastUpdatedOn());
+    return voyageReport;
+  }
+
+  // --- Private methods ---
+
+  private CargoReport loadCargoReport(String trackingId) {
+    try {
+      return (CargoReport) jdbc.queryForObject("select * from cargo where cargo_tracking_id = ?", new String[] {trackingId}, cargoReportRowMapper);
+    } catch (EmptyResultDataAccessException e) {
+      return null;
+    }
+  }
+
+  private List<CargoReport.Handling> loadHandlings(String trackingId) {
+    final List<CargoReport.Handling> handlings = new ArrayList<CargoReport.Handling>();
+    RowCallbackHandler handler = new RowCallbackHandler() {
+      @Override
+      public void processRow(ResultSet rs) throws SQLException {
+        handlings.add(handlingRowMapper.mapRow(rs, rs.getRow()));
+      }
+    };
+    String[] args = {trackingId};
+    String sql = "select * from handling where cargo_tracking_id = ?";
+    jdbc.query(sql, args, handler);
+    return handlings;
+  }
+
+  private VoyageReport loadVoyageReport(String voyageNumber) {
+    String[] args = {voyageNumber};
+    String sql = "select * from voyage where voyage_number = ?";
+    return (VoyageReport) jdbc.queryForObject(sql, args, rowMapper);
+  }
+
+  ReportingService() {
+    // Needed by CGLIB
+  }
+  
 }

dddsample/external/reporting/src/main/java/com.reporting/VoyageReport.java

@@ -1,4 +1,63 @@
 package com.reporting;
 
+import javax.xml.bind.annotation.XmlRootElement;
+import java.util.Date;
+
+@XmlRootElement(name = "voyage")
 public class VoyageReport {
+
+  private Date lastUpdatedOn;
+  private String voyageNumber;
+  private String nextStop;
+  private Date etaNextStop;
+  private String currentStatus;
+  private int delayedByMinutes;
+
+  public Date getLastUpdatedOn() {
+    return lastUpdatedOn;
+  }
+
+  public void setLastUpdatedOn(Date lastUpdatedOn) {
+    this.lastUpdatedOn = lastUpdatedOn;
+  }
+
+  public String getVoyageNumber() {
+    return voyageNumber;
+  }
+
+  public void setVoyageNumber(String voyageNumber) {
+    this.voyageNumber = voyageNumber;
+  }
+
+  public String getNextStop() {
+    return nextStop;
+  }
+
+  public void setNextStop(String nextStop) {
+    this.nextStop = nextStop;
+  }
+
+  public Date getEtaNextStop() {
+    return etaNextStop;
+  }
+
+  public void setEtaNextStop(Date etaNextStop) {
+    this.etaNextStop = etaNextStop;
+  }
+
+  public String getCurrentStatus() {
+    return currentStatus;
+  }
+
+  public void setCurrentStatus(String currentStatus) {
+    this.currentStatus = currentStatus;
+  }
+
+  public int getDelayedByMinutes() {
+    return delayedByMinutes;
+  }
+
+  public void setDelayedByMinutes(int delayedByMinutes) {
+    this.delayedByMinutes = delayedByMinutes;
+  }
 }

dddsample/external/reporting/src/main/java/com.reporting/VoyageReportRowMapper.java

@@ -0,0 +1,20 @@
+package com.reporting;
+
+import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+class VoyageReportRowMapper implements ParameterizedRowMapper<VoyageReport> {
+  @Override
+  public VoyageReport mapRow(ResultSet rs, int rowNum) throws SQLException {
+    VoyageReport voyageReport = new VoyageReport();
+    voyageReport.setVoyageNumber(rs.getString("voyage_number"));
+    voyageReport.setCurrentStatus(rs.getString("current_status"));
+    voyageReport.setDelayedByMinutes(rs.getInt("delayed_by_min"));
+    voyageReport.setEtaNextStop(rs.getDate("eta_next_stop"));
+    voyageReport.setLastUpdatedOn(rs.getDate("last_updated_on"));
+    voyageReport.setNextStop(rs.getString("next_stop"));
+    return voyageReport;
+  }
+}

dddsample/external/reporting/src/main/resources/context-cxf.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:jaxrs="http://cxf.apache.org/jaxrs"
+       xmlns:tx="http://www.springframework.org/schema/tx"
+       xsi:schemaLocation="
+        http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd
+        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.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-servlet.xml"/>
+  <import resource="classpath:META-INF/cxf/cxf-extension-jaxrs-binding.xml"/>
+  <import resource="classpath:META-INF/cxf/cxf-extension-http.xml" />
+
+  <jaxrs:server address="/">
+    <jaxrs:serviceBeans>
+      <ref bean="reportingService"/>
+    </jaxrs:serviceBeans>
+  </jaxrs:server>
+
+</beans>

dddsample/external/reporting/src/main/resources/context.xml

@@ -0,0 +1,29 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:jaxrs="http://cxf.apache.org/jaxrs"
+       xmlns:tx="http://www.springframework.org/schema/tx"
+       xsi:schemaLocation="
+        http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd
+        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
+        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+
+  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
+    <property name="dataSource" ref="dataSource"/>
+  </bean>
+
+  <tx:annotation-driven transaction-manager="transactionManager"/>
+
+  <bean id="reportingService" class="com.reporting.ReportingService">
+    <constructor-arg ref="dataSource"/>
+  </bean>
+
+  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
+    <property name="url" value="jdbc:hsqldb:mem:reporting"/>
+    <property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
+    <property name="username" value="sa"/>
+    <property name="password" value=""/>
+  </bean>
+
+</beans>

dddsample/external/reporting/src/main/resources/schema.sql

@@ -0,0 +1,29 @@
+create table cargo (
+  cargo_tracking_id varchar not null primary key,
+  received_in varchar,
+  destination varchar,
+  arrival_deadline timestamp,
+  eta timestamp,
+  current_status varchar,
+  current_voyage_number varchar,
+  current_location varchar,
+  last_updated_on timestamp
+)
+
+create table handling (
+  cargo_tracking_id varchar not null,
+  type varchar,
+  location varchar,
+  voyage_number varchar,
+  completed_on timestamp,
+  foreign key (cargo_tracking_id) references cargo(cargo_tracking_id)
+)
+
+create table voyage (
+  voyage_number varchar not null primary key,
+  next_stop varchar,
+  eta_next_stop timestamp,
+  current_status varchar not null,
+  delayed_by_min int not null,
+  last_updated_on timestamp
+)

dddsample/external/reporting/src/main/webapp/WEB-INF/web.xml

@@ -21,7 +21,21 @@
 
   <context-param>
     <param-name>contextConfigLocation</param-name>
-    <param-value>classpath:applicationContext.xml</param-value>
+    <param-value>
+      classpath:context.xml
+      classpath:context-cxf.xml
+    </param-value>
   </context-param>
 
+  <servlet>
+    <servlet-name>cxf</servlet-name>
+    <servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class>
+    <load-on-startup>1</load-on-startup>
+  </servlet>
+
+  <servlet-mapping>
+    <servlet-name>cxf</servlet-name>
+    <url-pattern>/*</url-pattern>
+  </servlet-mapping>
+
 </web-app>

dddsample/external/reporting/src/test/java/com/reporting/Fixture.java

@@ -0,0 +1,42 @@
+/**
+ * Purpose
+ * @author peter
+ * @created 2009-okt-03
+ * $Id$
+ */
+package com.reporting;
+
+import org.apache.commons.io.IOUtils;
+import org.springframework.context.ApplicationEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextRefreshedEvent;
+import org.springframework.core.io.Resource;
+import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;
+
+import javax.sql.DataSource;
+import java.io.IOException;
+
+public class Fixture implements ApplicationListener {
+
+  private SimpleJdbcTemplate jdbc;
+  private Resource schema;
+  private Resource testdata;
+
+  public Fixture(DataSource dataSource, Resource schema, Resource testdata) {
+    this.jdbc = new SimpleJdbcTemplate(dataSource);
+    this.testdata = testdata;
+    this.schema = schema;
+  }
+
+  @Override
+  public void onApplicationEvent(ApplicationEvent event) {
+    if (event instanceof ContextRefreshedEvent) {
+      try {
+        jdbc.update(IOUtils.toString(schema.getInputStream()));
+        jdbc.update(IOUtils.toString(testdata.getInputStream()));
+      } catch (IOException e) {
+        throw new RuntimeException(e);
+      }
+    }
+  }
+}

dddsample/external/reporting/src/test/java/com/reporting/ReportServiceTest.java

@@ -0,0 +1,71 @@
+package com.reporting;
+
+import org.apache.commons.io.IOUtils;
+import org.codehaus.jettison.json.JSONObject;
+import org.codehaus.jettison.json.JSONException;
+import org.codehaus.jettison.json.JSONArray;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.*;
+import org.junit.Test;
+import org.junit.Assert;
+import org.junit.runner.RunWith;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import java.net.URL;
+import java.net.URLConnection;
+import java.io.IOException;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations={"/context.xml", "/context-cxf.xml", "/context-test-setup.xml"})
+public class ReportServiceTest {
+
+  @Test
+  public void deliveryReport() throws Exception {
+    JSONObject json = readJSON("/report/cargo/ABC");
+    JSONObject cargo = json.getJSONObject("cargo");
+    
+    assertEquals("ABC", cargo.get("trackingId"));
+    assertEquals("Hongkong", cargo.get("receivedIn"));
+    assertEquals("Stockholm", cargo.get("finalDestination"));
+    assertEquals("6/15/09 12:00 PM", cargo.get("arrivalDeadline"));
+    assertEquals("6/12/09 6:30 PM", cargo.get("eta"));
+    assertEquals("Onboard voyage", cargo.get("currentStatus"));
+    assertEquals("V0100", cargo.get("currentVoyage"));
+    assertEquals("Tokyo", cargo.get("currentLocation"));
+    assertEquals("6/8/09 2:23 PM", cargo.get("lastUpdatedOn"));
+
+    JSONArray handlings = cargo.getJSONArray("handlings");
+    assertEquals(4, handlings.length());
+
+    verifyHandling(handlings.getJSONObject(0), "Receive", "Hongkong", null);
+    verifyHandling(handlings.getJSONObject(1), "Load", "Hongkong", "V0100");
+    verifyHandling(handlings.getJSONObject(2), "Unload", "Long Beach", "V0100");
+    verifyHandling(handlings.getJSONObject(3), "Load", "Long Beach", "V0200");
+  }
+
+  private void verifyHandling(JSONObject handling, String type, String location, String voyage) throws JSONException {
+    assertEquals(type, handling.get("type"));
+    assertEquals(location, handling.get("location"));
+    if (voyage == null) {
+      assertFalse(handling.has("voyage"));
+    } else {
+      assertEquals(voyage, handling.get("voyage"));
+    }
+  }
+
+  @Test
+  public void voyageReport() throws Exception {
+    JSONObject json = readJSON("/report/voyage/V0200");
+    JSONObject voyage = json.getJSONObject("voyage");
+
+    assertEquals("V0200", voyage.get("voyageNumber"));
+  }
+
+  private JSONObject readJSON(String path) throws IOException, JSONException {
+    URLConnection urlConnection = new URL("http://localhost:14000" + path).openConnection();
+    String jsonString = IOUtils.toString(urlConnection.getInputStream());
+    return new JSONObject(jsonString);
+  }
+
+}

dddsample/external/reporting/src/test/resources/context-cxf.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0"?>
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:jaxrs="http://cxf.apache.org/jaxrs"
+       xmlns:tx="http://www.springframework.org/schema/tx"
+       xsi:schemaLocation="
+        http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd
+        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.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-servlet.xml"/>
+  <import resource="classpath:META-INF/cxf/cxf-extension-jaxrs-binding.xml"/>
+  <import resource="classpath:META-INF/cxf/cxf-extension-http-jetty.xml" />
+
+  <jaxrs:server address="http://localhost:14000" id="jaxRsService">
+    <jaxrs:serviceBeans>
+      <ref bean="reportingService"/>
+    </jaxrs:serviceBeans>
+  </jaxrs:server>
+
+</beans>

dddsample/external/reporting/src/test/resources/context-test-setup.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 class="com.reporting.Fixture">
+    <constructor-arg ref="dataSource"/>
+    <constructor-arg value="classpath:schema.sql"/>
+    <constructor-arg value="classpath:testdata.sql"/>
+  </bean>
+
+</beans>

dddsample/external/reporting/src/test/resources/testdata.sql

@@ -0,0 +1,67 @@
+insert into cargo (
+  cargo_tracking_id,
+  received_in,
+  destination,
+  arrival_deadline,
+  eta,
+  current_status,
+  current_voyage_number,
+  current_location,
+  last_updated_on
+) values (
+  'ABC',
+  'Hongkong',
+  'Stockholm',
+  '2009-06-15 12:00:00.000',
+  '2009-06-12 18:30:00.000',
+  'Onboard voyage',
+  'V0100',
+  'Tokyo',
+  '2009-06-08 14:23:12.123'
+);
+
+insert into handling (cargo_tracking_id, type,location,voyage_number,completed_on)
+values ('ABC','Receive','Hongkong',  null,   '2009-05-30 07:32:00.000');
+
+insert into handling (cargo_tracking_id, type,location,voyage_number,completed_on)
+values ('ABC','Load',   'Hongkong',  'V0100','2009-05-31 13:37:00.000');
+
+insert into handling (cargo_tracking_id, type,location,voyage_number,completed_on)
+values ('ABC','Unload', 'Long Beach','V0100','2009-06-04 19:01:00.000');
+
+insert into handling (cargo_tracking_id, type,location,voyage_number,completed_on)
+values ('ABC','Load',   'Long Beach','V0200','2009-06-06 22:50:00.000');
+
+insert into voyage (
+  voyage_number,
+  next_stop,
+  eta_next_stop,
+  current_status,
+  delayed_by_min,
+  last_updated_on
+)
+values (
+  'V0100',
+  'Honolulu',
+  '',
+  'In port',
+  '300',
+  ''
+);
+
+insert into voyage (
+  voyage_number,
+  next_stop,
+  eta_next_stop,
+  current_status,
+  delayed_by_min,
+  last_updated_on
+)
+values (
+  'V0200',
+  'Seattle',
+  '',
+  'In transit',
+  '0',
+  ''
+);