!!! Im Text referenzierte Listings

!!! #REF1. Lieferscheinverarbeitung, umgesetzt mit
!!! Spring Batch

<bean id="deliveryNoteCsvReader" class="org.springframework.batch.item.file.FlatFileItemReader"
         scope="prototype">
	<property name="encoding" value="UTF-8" />
	<property name="lineMapper">
	<bean class="org.springframework.batch.item.file.mapping.DefaultLineMapper">
			<property name="lineTokenizer">
				<bean
					class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer">
					<property name="delimiter" value=";" />
					<property name="names" value="itemType,name,number,price,quantity" />
				</bean>
			</property>
			<property name="fieldSetMapper">
				<bean class="eip.spring.integration.StockItemFieldSetMapper" />
			</property>
		</bean>
	</property>
</bean>
    
!!! - DelimitedLineTokenizer: teilt jede Zeile in einzelne Felder.
!!! - DefaultLineMapper: lässt den DelimitedLineTokenizer die Zeile zerlegen und StockItemFieldSetMapper daraus einen Objekt erzeugen
!!!- FlatFileItemReader: liest die CSV Datei zeilenweise.

!!! #REF2. Spring Integration überwacht das
!!! Dateisystem/den Ordner und leitet neue Lieferscheine an
!!! den Kommunikationskanal csvDeliveryNotesChannel weiter.

<int-file:inbound-channel-adapter id="deliveryNotesChannelAdapter"
	directory="file:../eip-common/src/main/resources/deliverynotes" channel="csvDeliveryNotesChannel">
	<int:poller fixed-rate="1000" />
</int-file:inbound-channel-adapter>

!!! #REF3. Der Service Activator horcht auf Nachrichten
!!! am Kommunikationskanal csvDeliveryNotesChannel und
!!! leitet sie an den CSV-Importer weiter, der die
!!! gelesenen Lieferscheinbestandteile mittels stockWriterAdapter in
!!! die Datenbank schreibt. 

<int:service-activator input-channel="csvDeliveryNotesChannel"
	ref="deliveryNoteCsvImport" method="importCsv" />


!!! Die Spring Konfiguration der verwendete Beans: 
	
<bean id="deliveryNoteCsvImport" class="eip.spring.integration.DeliveryNoteCsvImport"
	scope="prototype">
	<constructor-arg name="reader" ref="deliveryNoteCsvReader" />
	<constructor-arg name="writer" ref="stockWriterAdapter" />
</bean>

<bean id="stockWriterAdapter"
	class="org.springframework.batch.item.adapter.ItemWriterAdapter">
	<property name="targetObject" ref="stockService" />
	<property name="targetMethod" value="addStockItem" />
</bean>

!!! REF4. In der Nachrichtenkette platziert, wandelt
!!! Apache Camels Processor die eingehende
!!! Nachricht in eine SMS- oder Mail-Benachrichtigung um.

public void process(final Exchange exchange) throws Exception {
    Notification notification = exchange.getIn()
            .getBody(Notification.class);
    if (notification.getContactChannel(notification.getCustomer()).equals(SMS))
        exchange.getIn().setBody(
                new SmsNotification(notification.getCustomer(),
                 		notification.getMessage(), 
                       		customerConfig.getSmsNumber(notification.getCustomer()));
    else
        exchange.getIn().setBody(
                new MailNotification(notification.getCustomer(),
                        	notification.getMessage(), 
                                customerConfig.getMailAddressNumber(notification.getCustomer()),
                                customerConfig.getMailSubject(notification.getCustomer()));
    }

!!! #REF5. Die von Apache Camel benötigte
!!! Routing-Implementierung definiert die Route des
!!! Nachrichtentyps.

public String slip(final Notification notification,
    @Properties Map<String, Object> properties) {
    // End routing by returning null, otherwise endless loop
    // The current endpoint is in the properties.
    // First run - where routing should be done - it will be null
    if (properties.get(Exchange.SLIP_ENDPOINT) != null) {
    return null;
    }
    if (notification instanceof SmsNotification) {
        return "activemq:sms";
    } else if (notification instanceof MailNotification) {
        return "activemq:mail";
    }
    return null;
}

!!! #REF6. Die (Spring-)Konfiguration der einzelnen
!!! Elemente der Verarbeitungskette im
!!! Benachrichtigungsprozess von Apache Camel.

<camel:camelContext id="activeMqTest">
    <camel:proxy id="notificationService" serviceInterface="eip.common.services.NotificationService"
        serviceUrl="direct:notification" />

    <camel:route>
        <camel:from uri="direct:notification"/>
        <camel:bean ref="notificationEnricher"/>
        <camel:dynamicRouter>
            <camel:method ref="notificationRouter" method="slip"/>
        </camel:dynamicRouter>
    </camel:route>
    <camel:route>
        <camel:from uri="activemq:sms" />
        <camel:bean ref="smsServiceMock" />
    </camel:route>
    <camel:route>
        <camel:from uri="activemq:mail" />
        <camel:bean ref="mailServiceMock" />
    </camel:route>
</camel:camelContext>

<bean id="notificationEnricher" class="eip.camel.NotificationEnricher"/>
<bean id="notificationRouter" class="eip.camel.NotificationRouter"/>
    
<bean id="smsServiceMock" factory-method="mock" class="org.mockito.Mockito">
    <constructor-arg value="eip.common.services.SmsService" />
</bean>
<bean id="mailServiceMock" factory-method="mock" class="org.mockito.Mockito">
    <constructor-arg value="eip.common.services.MailService" />
</bean>

!!! #REF7. Die Implementierung des Webservice-Client
!!! mit Spring Integration stützt sich auf den im
!!! Funktionsumfang enthaltenen WebServiceGatewaySupport
!!! und auf autogenerierte Java-Objekte für die
!!! Interaktion.

public class PartsOrderService extends WebServiceGatewaySupport {
     public OrderResponse order(OrderRequest orderRequest) {
         OrderResponse response = (OrderResponse) getWebServiceTemplate().marshalSendAndReceive(orderRequest);
         return response;
     };
}

!!! #REF8. Die Implementierung des Webservice-Client
!!! stüzt sich auf den XML-Marshaller.

<bean id="marshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
    <property name="contextPath" value="parts.eip" />
</bean>

<bean id="webserviceTemplate" class="parts.eip.PartsOrderService" >
    <property name="defaultUri" value="http://localhost:8080/eip-webservice-camel/partsOrder"></property>
    <property name="marshaller" ref="marshaller" />
    <property name="unmarshaller" ref="marshaller" />
</bean>