Updates to business chapter code

Author: mbogoevici

siia-examples-parent/business/src/main/java/siia/business/AuditService.java

@@ -0,0 +1,10 @@
+package siia.business;
+
+/**
+ * @author Marius Bogoevici
+ */
+public class AuditService {
+  public void audit(Object payload) {
+
+  }
+}

siia-examples-parent/business/src/main/java/siia/business/ChannelAuditor.java

@@ -0,0 +1,18 @@
+package siia.business;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.integration.Message;
+import org.springframework.integration.MessageChannel;
+import org.springframework.integration.channel.interceptor.ChannelInterceptorAdapter;
+
+public class ChannelAuditor extends ChannelInterceptorAdapter {
+
+  @Autowired
+  private AuditService auditService;
+
+  public Message<?> preSend(Message<?> message,
+                                MessageChannel channel) {
+        this.auditService.audit(message.getPayload());
+        return message;
+    }
+}

siia-examples-parent/business/src/main/java/siia/business/EmailHeaderEnricher.java

@@ -8,15 +8,14 @@
 
 import java.util.Map;
 
-/**
- * @author Marius Bogoevici
- */
 @MessageEndpoint
 public class EmailHeaderEnricher {
 
-    public Message<Passenger> populateEmailHeader(Passenger passenger, @Headers Map<String, Object> headers) {
+    public Message<Passenger> populateEmailHeader(Passenger passenger,
+                               @Headers Map<String, Object> headers) {
 
-        MessageBuilder<Passenger> responseBuilder = MessageBuilder.withPayload(passenger).copyHeaders(headers);
+        MessageBuilder<Passenger> responseBuilder =
+            MessageBuilder.withPayload(passenger).copyHeaders(headers);
         Profile profile = passenger.getProfile();
         if (profile != null) {
             String emailAddress = profile.getEmailAddress();

siia-examples-parent/business/src/main/java/siia/business/Flight.java

@@ -3,9 +3,6 @@
 import java.util.Date;
 import java.util.Map;
 
-/**
- * @author Marius Bogoevici
- */
 public class Flight {
     private String number;
     private Date scheduledDeparture;

siia-examples-parent/business/src/main/java/siia/business/FlightEventTransformer.java

@@ -6,29 +6,28 @@
 
 import java.util.Calendar;
 
-/**
- * @author Marius Bogoevici
- */
 @MessageEndpoint
 public class FlightEventTransformer {
-    private final FlightScheduler flightScheduler;
+  private final FlightScheduler flightScheduler;
 
-    @Autowired
-    public FlightEventTransformer(FlightScheduler flightScheduler) {
-        Assert.notNull(flightScheduler, "flightScheduler must not be null");
-        this.flightScheduler = flightScheduler;
-    }
+  @Autowired
+  public FlightEventTransformer(FlightScheduler flightScheduler) {
+    Assert.notNull(flightScheduler,
+        "flightScheduler must not be null");
+    this.flightScheduler = flightScheduler;
+  }
 
-    public FlightDelayEvent convertToDelayEvent(String flightNumberAndDelay) {
-        String[] splits = flightNumberAndDelay.split("[+]");
-        Flight flight =
-                this.flightScheduler.nextFlightForNumber(splits[0]);
-        int hours = Integer.parseInt(splits[1].substring(0, 2));
-        int minutes = Integer.parseInt(splits[1].substring(2));
-        Calendar cal = Calendar.getInstance();
-        cal.setTime(flight.getScheduledDeparture());
-        cal.add(Calendar.HOUR, hours);
-        cal.add(Calendar.MINUTE, minutes);
-        return new FlightDelayEvent(flight, cal.getTime());
-    }
+  public FlightDelayEvent convertToDelayEvent(
+      String flightNumberAndDelay) {
+    String[] splits = flightNumberAndDelay.split("[+]");
+    Flight flight =
+        this.flightScheduler.nextFlightForNumber(splits[0]);
+    int hours = Integer.parseInt(splits[1].substring(0, 2));
+    int minutes = Integer.parseInt(splits[1].substring(2));
+    Calendar cal = Calendar.getInstance();
+    cal.setTime(flight.getScheduledDeparture());
+    cal.add(Calendar.HOUR, hours);
+    cal.add(Calendar.MINUTE, minutes);
+    return new FlightDelayEvent(flight, cal.getTime());
+  }
 }

siia-examples-parent/business/src/main/java/siia/business/FlightStatusService.java

@@ -1,6 +1,6 @@
 package siia.business;
 
 public interface FlightStatusService {
-    FlightStatus updateStatus(FlightDelayEvent flightDelayEvent);
+    void updateStatus(FlightDelayEvent flightDelayEvent);
 }
 

siia-examples-parent/business/src/main/java/siia/business/PassengerProfileEnricher.java

@@ -3,9 +3,6 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.integration.annotation.MessageEndpoint;
 
-/**
- * @author Marius Bogoevici
- */
 @MessageEndpoint
 public class PassengerProfileEnricher {
 

siia-examples-parent/business/src/main/java/siia/business/SimpleFlightStatusService.java

@@ -1,14 +1,18 @@
 package siia.business;
 
+
+import org.springframework.integration.annotation.Payload;
 import org.springframework.integration.annotation.Publisher;
 
 /**
  * @author Marius Bogoevici
  */
 public class SimpleFlightStatusService implements FlightStatusService {
+
     @Override
     @Publisher(channel = "statisticsChannel")
-    public FlightStatus updateStatus(FlightDelayEvent flightDelayEvent) {
-        return new FlightStatus();
+    public void updateStatus(@Payload FlightDelayEvent
+                             flightDelayEvent) {
+        // update status
     }
 }

siia-examples-parent/business/src/main/resources/chain.xml

@@ -3,19 +3,24 @@
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:mail="http://www.springframework.org/schema/integration/mail"
        xmlns="http://www.springframework.org/schema/integration"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
-       http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/mail/spring-integration.xsd
-       http://www.springframework.org/schema/integration/mail http://www.springframework.org/schema/integration/mail/spring-integration-mail.xsd">
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+       http://www.springframework.org/schema/beans/spring-beans.xsd
+       http://www.springframework.org/schema/integration
+       http://www.springframework.org/schema/integration/mail/spring-integration.xsd
+       http://www.springframework.org/schema/integration/mail
+       http://www.springframework.org/schema/integration/mail/spring-integration-mail.xsd">
 
     <chain input-channel="passengers">
-        <transformer ref="frequentFlyerService" method="configureProfile"/>
+        <transformer ref="frequentFlyerService"
+                     method="configureProfile"/>
         <header-enricher>
-            <header name="#{MailHeaders.TO}" value="#{payload.emailAddress}"/>
+            <header name="#{MailHeaders.TO}"
+                    value="#{payload.emailAddress}"/>
         </header-enricher>
         <mail:outbound-channel-adapter mail-sender="mailSender"/>
     </chain>
 
-    <beans:bean class="com.manning.siia.business.StubFrequentFlyerService"/>
+    <beans:bean class="siia.business.StubFrequentFlyerService"/>
 
 
 </beans:beans>

siia-examples-parent/business/src/main/resources/flightStatus.xml

@@ -6,5 +6,6 @@
              http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd">
 
     <service-activator input-channel="flightDelays" ref="flightStatusService" method="updateStatus"/>
-    <beans:bean id="flightStatusService" class="com.manning.siia.business.SimpleFlightStatusService"/>
+    <beans:bean id="flightStatusService" class="siia.business
+    .SimpleFlightStatusService"/>
 </beans:beans>