moved org.springframework.integration.samples module to spring-integration-samples

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/Cafe.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe;
+
+import org.springframework.integration.annotation.Gateway;
+
+/**
+ * The entry point for Cafe Demo. The demo's main() method invokes the
+ * '<code>placeOrder</code>' method on a generated MessagingGateway proxy.
+ * The gateway then passes the {@link Order} as the payload of a
+ * {@link org.springframework.integration.core.Message} to the
+ * configured <em>requestChannel</em>. The channel ('orders') is
+ * defined in the 'cafeDemo.xml' file.
+ * 
+ * @author Mark Fisher
+ */
+public interface Cafe { 
+
+	@Gateway(requestChannel="orders")
+	void placeOrder(Order order);
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/Delivery.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe;
+
+import java.util.List;
+
+/**
+ * @author Marius Bogoevici
+ */
+public class Delivery {
+
+	private static final String SEPARATOR = "-----------------------";
+
+
+    private List<Drink> deliveredDrinks;
+
+	private int orderNumber;
+
+
+	public Delivery(List<Drink> deliveredDrinks) {
+		assert(deliveredDrinks.size() > 0);
+        this.deliveredDrinks = deliveredDrinks;
+		this.orderNumber = deliveredDrinks.get(0).getOrderNumber();
+    }
+
+
+    public int getOrderNumber() {
+		return orderNumber;
+	}
+
+	public List<Drink> getDeliveredDrinks() {
+        return deliveredDrinks;
+    }
+
+	@Override
+	public String toString() {
+		StringBuffer buffer = new StringBuffer(SEPARATOR + "\n");
+		buffer.append("Order #" + getOrderNumber() + "\n");
+		for (Drink drink : getDeliveredDrinks()) {
+			buffer.append(drink);
+			buffer.append("\n");
+		}
+		buffer.append(SEPARATOR + "\n");
+		return buffer.toString();
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/Drink.java

@@ -0,0 +1,50 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe;
+
+/**
+ * @author Marius Bogoevici
+ */
+public class Drink {
+
+    private boolean iced;
+
+    private int shots;
+
+    private DrinkType drinkType;
+
+	private int orderNumber;
+
+	
+    public Drink(int orderNumber, DrinkType drinkType, boolean hot, int shots) {
+	    this.orderNumber = orderNumber;
+        this.drinkType = drinkType;
+        this.iced = hot;
+        this.shots = shots;
+    }
+
+
+	public int getOrderNumber() {
+		return orderNumber;
+	}
+
+	@Override
+    public String toString() {
+        return (iced?"Iced":"Hot")  + " " + drinkType.toString() + ", " + shots + " shots.";
+    }
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/DrinkType.java

@@ -0,0 +1,29 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe;
+
+/**
+ * @author Mark Fisher
+ */
+public enum DrinkType {
+
+	ESPRESSO,
+	LATTE,
+	CAPPUCCINO,
+	MOCHA
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/Order.java

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class Order {
+
+	private List<OrderItem> orderItems = new ArrayList<OrderItem>();
+
+	private int number;
+
+	public Order(int number) {
+		this.number = number;
+	}
+
+	public void addItem(DrinkType drinkType, int shots, boolean iced) {
+		this.orderItems.add(new OrderItem(this, drinkType, shots, iced));
+	}
+
+	public int getNumber() {
+		return number;
+	}
+
+	public List<OrderItem> getItems() {
+		return this.orderItems;
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/OrderItem.java

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe;
+
+/**
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class OrderItem {
+
+    private DrinkType type;
+
+    private int shots = 1;
+
+    private boolean iced = false;
+
+	private final Order order;
+
+
+	public OrderItem(Order order, DrinkType type, int shots, boolean iced) {
+        this.order = order;
+		this.type = type;
+        this.shots = shots;
+        this.iced = iced;
+    }
+
+
+	public Order getOrder() {
+		return this.order;
+	}
+
+	public boolean isIced() {
+        return this.iced;
+    }
+
+    public int getShots() {
+        return shots;
+    }
+
+    public DrinkType getDrinkType() {
+        return this.type;
+    }
+
+    public String toString() {
+        return ((this.iced) ? "iced " : "hot ") + this.shots + " shot " + this.type;
+    }
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/annotation/Barista.java

@@ -0,0 +1,80 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.annotation;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import org.springframework.integration.annotation.ServiceActivator;
+import org.springframework.integration.samples.cafe.Drink;
+import org.springframework.integration.samples.cafe.OrderItem;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+@Component
+public class Barista {
+
+	private long hotDrinkDelay = 5000;
+
+	private long coldDrinkDelay = 1000;
+
+	private AtomicInteger hotDrinkCounter = new AtomicInteger();
+
+	private AtomicInteger coldDrinkCounter = new AtomicInteger();
+
+
+	public void setHotDrinkDelay(long hotDrinkDelay) {
+		this.hotDrinkDelay = hotDrinkDelay;
+	}
+
+	public void setColdDrinkDelay(long coldDrinkDelay) {
+		this.coldDrinkDelay = coldDrinkDelay;
+	}
+
+	@ServiceActivator(inputChannel="hotDrinkBarista", outputChannel="preparedDrinks")
+	public Drink prepareHotDrink(OrderItem orderItem) {
+		try {
+			Thread.sleep(this.hotDrinkDelay);
+			System.out.println(Thread.currentThread().getName()
+					+ " prepared hot drink #" + hotDrinkCounter.incrementAndGet() + " for order #"
+					+ orderItem.getOrder().getNumber() + ": " + orderItem);
+			return new Drink(orderItem.getOrder().getNumber(), orderItem.getDrinkType(), orderItem.isIced(),
+					orderItem.getShots());
+		} catch (InterruptedException e) {
+			Thread.currentThread().interrupt();
+			return null;
+		}
+	}
+
+	@ServiceActivator(inputChannel="coldDrinkBarista", outputChannel="preparedDrinks")
+	public Drink prepareColdDrink(OrderItem orderItem) {
+		try {
+			Thread.sleep(this.coldDrinkDelay);
+			System.out.println(Thread.currentThread().getName()
+					+ " prepared cold drink #" + coldDrinkCounter.incrementAndGet() + " for order #"
+					+ orderItem.getOrder().getNumber() + ": " + orderItem);
+			return new Drink(orderItem.getOrder().getNumber(), orderItem.getDrinkType(), orderItem.isIced(),
+					orderItem.getShots());
+		} catch (InterruptedException e) {
+			Thread.currentThread().interrupt();
+			return null;
+		}
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/annotation/CafeDemo.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.annotation;
+
+import org.springframework.context.support.AbstractApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+import org.springframework.context.support.FileSystemXmlApplicationContext;
+import org.springframework.integration.samples.cafe.Cafe;
+import org.springframework.integration.samples.cafe.DrinkType;
+import org.springframework.integration.samples.cafe.Order;
+
+/**
+ * Provides the 'main' method for running the Cafe Demo application. When an
+ * order is placed, the Cafe will send that order to the "orders" channel.
+ * The channels are defined within the configuration file ("cafeDemo.xml"),
+ * and the relevant components are configured with annotations (such as the
+ * OrderSplitter, DrinkRouter, and Barista classes).
+ * 
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class CafeDemo {
+
+	public static void main(String[] args) {
+		AbstractApplicationContext context = null;
+		if(args.length > 0) {
+			context = new FileSystemXmlApplicationContext(args);
+		}
+		else {
+			context = new ClassPathXmlApplicationContext("cafeDemo.xml", CafeDemo.class);
+		}
+		Cafe cafe = (Cafe) context.getBean("cafe");
+		for (int i = 1; i <= 100; i++) {
+			Order order = new Order(i);
+			order.addItem(DrinkType.LATTE, 2, false);
+			order.addItem(DrinkType.MOCHA, 3, true);
+			cafe.placeOrder(order);
+		}
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/annotation/DrinkRouter.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.annotation;
+
+import org.springframework.integration.annotation.MessageEndpoint;
+import org.springframework.integration.annotation.Router;
+import org.springframework.integration.samples.cafe.OrderItem;
+
+/**
+ * @author Mark Fisher
+ */
+@MessageEndpoint
+public class DrinkRouter {
+
+	@Router(inputChannel="drinks")
+	public String resolveOrderItemChannel(OrderItem orderItem) {
+		return (orderItem.isIced()) ? "coldDrinks" : "hotDrinks";
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/annotation/OrderSplitter.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.annotation;
+
+import java.util.List;
+
+import org.springframework.integration.annotation.MessageEndpoint;
+import org.springframework.integration.annotation.Splitter;
+import org.springframework.integration.samples.cafe.Order;
+import org.springframework.integration.samples.cafe.OrderItem;
+
+/**
+ * @author Mark Fisher
+ */
+@MessageEndpoint
+public class OrderSplitter {
+
+	@Splitter(inputChannel="orders", outputChannel="drinks")
+	public List<OrderItem> split(Order order) {
+		return order.getItems();
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/annotation/Waiter.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.annotation;
+
+import java.util.List;
+
+import org.springframework.integration.annotation.Aggregator;
+import org.springframework.integration.annotation.CorrelationStrategy;
+import org.springframework.integration.annotation.MessageEndpoint;
+import org.springframework.integration.samples.cafe.Delivery;
+import org.springframework.integration.samples.cafe.Drink;
+
+/**
+ * @author Marius Bogoevici
+ */
+@MessageEndpoint
+public class Waiter {
+
+    @Aggregator(inputChannel = "preparedDrinks", outputChannel = "deliveries", timeout = 5 * 60 * 1000)
+    public Delivery prepareDelivery(List<Drink> drinks) {
+        return new Delivery(drinks);
+    }
+    
+    @CorrelationStrategy
+    public int correlateByOrderNumber(Drink drink) {
+    	return drink.getOrderNumber();
+    }
+    
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/annotation/cafeDemo.xml

@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans:beans xmlns="http://www.springframework.org/schema/integration"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:beans="http://www.springframework.org/schema/beans"
+	xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+			http://www.springframework.org/schema/context
+			http://www.springframework.org/schema/context/spring-context-2.5.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">
+
+	<annotation-config/>
+
+	<context:component-scan base-package="org.springframework.integration.samples.cafe.annotation"/>
+
+	<gateway id="cafe" service-interface="org.springframework.integration.samples.cafe.Cafe"/>
+
+	<channel id="orders"/>
+	<channel id="drinks"/>
+	<channel id="coldDrinks"><queue capacity="10"/></channel>
+	<channel id="hotDrinks"><queue capacity="10"/></channel>
+	<channel id="coldDrinkBarista"/>
+	<channel id="hotDrinkBarista"/>
+    <channel id="preparedDrinks"/>
+
+	<bridge input-channel="coldDrinks" output-channel="coldDrinkBarista">
+		<poller>
+			<interval-trigger interval="1000"/>
+		</poller>
+	</bridge>
+
+	<bridge input-channel="hotDrinks" output-channel="hotDrinkBarista">
+		<poller>
+			<interval-trigger interval="1000"/>
+		</poller>
+	</bridge>
+
+	<stream:stdout-channel-adapter id="deliveries"/>
+	
+</beans:beans>

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/xml/Barista.java

@@ -0,0 +1,75 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.xml;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import org.springframework.integration.samples.cafe.Drink;
+import org.springframework.integration.samples.cafe.OrderItem;
+
+/**
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class Barista {
+ 
+	private long hotDrinkDelay = 5000;
+
+	private long coldDrinkDelay = 1000;
+
+	private AtomicInteger hotDrinkCounter = new AtomicInteger();
+
+	private AtomicInteger coldDrinkCounter = new AtomicInteger();
+
+
+	public void setHotDrinkDelay(long hotDrinkDelay) {
+		this.hotDrinkDelay = hotDrinkDelay;
+	}
+
+	public void setColdDrinkDelay(long coldDrinkDelay) {
+		this.coldDrinkDelay = coldDrinkDelay;
+	}
+
+	public Drink prepareHotDrink(OrderItem orderItem) {
+		try {
+			Thread.sleep(this.hotDrinkDelay);
+			System.out.println(Thread.currentThread().getName()
+					+ " prepared hot drink #" + hotDrinkCounter.incrementAndGet() + " for order #"
+					+ orderItem.getOrder().getNumber() + ": " + orderItem);
+			return new Drink(orderItem.getOrder().getNumber(), orderItem.getDrinkType(), orderItem.isIced(),
+					orderItem.getShots());
+		} catch (InterruptedException e) {
+			Thread.currentThread().interrupt();
+			return null;
+		}
+	}
+
+	public Drink prepareColdDrink(OrderItem orderItem) {
+		try {
+			Thread.sleep(this.coldDrinkDelay);
+			System.out.println(Thread.currentThread().getName()
+					+ " prepared cold drink #" + coldDrinkCounter.incrementAndGet() + " for order #"
+					+ orderItem.getOrder().getNumber() + ": " + orderItem);
+			return new Drink(orderItem.getOrder().getNumber(), orderItem.getDrinkType(), orderItem.isIced(),
+					orderItem.getShots());
+		} catch (InterruptedException e) {
+			Thread.currentThread().interrupt();
+			return null;
+		}
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/xml/CafeDemo.java

@@ -0,0 +1,54 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.xml;
+
+import org.springframework.context.support.AbstractApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+import org.springframework.context.support.FileSystemXmlApplicationContext;
+import org.springframework.integration.samples.cafe.Cafe;
+import org.springframework.integration.samples.cafe.DrinkType;
+import org.springframework.integration.samples.cafe.Order;
+
+/**
+ * Provides the 'main' method for running the Cafe Demo application. When an
+ * order is placed, the Cafe will send that order to the "orders" channel.
+ * The relevant components are defined within the configuration file
+ * ("cafeDemo.xml").
+ * 
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class CafeDemo {
+
+	public static void main(String[] args) {
+		AbstractApplicationContext context = null;
+		if(args.length > 0) {
+			context = new FileSystemXmlApplicationContext(args);
+		}
+		else {
+			context = new ClassPathXmlApplicationContext("cafeDemo.xml", CafeDemo.class);
+		}
+		Cafe cafe = (Cafe) context.getBean("cafe");
+		for (int i = 1; i <= 100; i++) {
+			Order order = new Order(i);
+			order.addItem(DrinkType.LATTE, 2, false);
+			order.addItem(DrinkType.MOCHA, 3, true);
+			cafe.placeOrder(order);
+		}
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/xml/DrinkRouter.java

@@ -0,0 +1,30 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.xml;
+
+import org.springframework.integration.samples.cafe.OrderItem;
+
+/**
+ * @author Mark Fisher
+ */
+public class DrinkRouter {
+
+	public String resolveOrderItemChannel(OrderItem orderItem) {
+		return (orderItem.isIced()) ? "coldDrinks" : "hotDrinks";
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/xml/OrderSplitter.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.xml;
+
+import java.util.List;
+
+import org.springframework.integration.samples.cafe.Order;
+import org.springframework.integration.samples.cafe.OrderItem;
+
+/**
+ * @author Mark Fisher
+ */
+public class OrderSplitter {
+
+	public List<OrderItem> split(Order order) {
+		return order.getItems();
+	}
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/xml/Waiter.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.cafe.xml;
+
+import java.util.List;
+
+import org.springframework.integration.samples.cafe.Delivery;
+import org.springframework.integration.samples.cafe.Drink;
+
+/**
+ * @author Marius Bogoevici
+ */
+public class Waiter {
+
+    public Delivery prepareDelivery(List<Drink> drinks) {
+        return new Delivery(drinks);
+    }
+
+}

spring-integration-samples/cafe/src/main/java/org/springframework/integration/samples/cafe/xml/cafeDemo.xml

@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans:beans xmlns="http://www.springframework.org/schema/integration"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:beans="http://www.springframework.org/schema/beans"
+	xmlns:stream="http://www.springframework.org/schema/integration/stream"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
+			http://www.springframework.org/schema/integration/stream
+			http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">
+
+	<gateway id="cafe" service-interface="org.springframework.integration.samples.cafe.Cafe"/>
+
+	<channel id="orders"/>
+	<splitter input-channel="orders" method="split" output-channel="drinks">
+		<beans:bean class="org.springframework.integration.samples.cafe.xml.OrderSplitter"/>
+	</splitter>
+
+	<channel id="drinks"/>
+	<router input-channel="drinks"  method="resolveOrderItemChannel">
+		<beans:bean class="org.springframework.integration.samples.cafe.xml.DrinkRouter"/>
+	</router>
+
+	<channel id="coldDrinks">
+		<queue capacity="10"/>
+	</channel>
+	<service-activator input-channel="coldDrinks" ref="barista" method="prepareColdDrink" output-channel="preparedDrinks"/>
+
+	<channel id="hotDrinks">
+		<queue capacity="10"/>
+	</channel>
+	<service-activator input-channel="hotDrinks" ref="barista" method="prepareHotDrink" output-channel="preparedDrinks"/>
+
+    <channel id="preparedDrinks"/>
+    <aggregator input-channel="preparedDrinks"  method="prepareDelivery" output-channel="deliveries">
+    	<beans:bean class="org.springframework.integration.samples.cafe.xml.Waiter"/>
+    </aggregator>
+
+	<stream:stdout-channel-adapter id="deliveries"/>
+
+	<beans:bean id="barista" class="org.springframework.integration.samples.cafe.xml.Barista"/>
+
+	<poller id="poller" default="true">
+		<interval-trigger interval="1000"/>
+	</poller>
+
+</beans:beans>