Providing XML and Annotation-based versions of Cafe Demo.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.
@@ -20,7 +20,7 @@ import org.springframework.integration.channel.MessageChannel;
 import org.springframework.integration.message.MessageBuilder;
 
 /**
- * The entry point for {@link CafeDemo}. When the '<code>placeOrder</code>'
+ * The entry point for Cafe Demo. When the '<code>placeOrder</code>'
  * method is invoked, it passes the {@link Order} as the payload of a
  * {@link org.springframework.integration.message.Message} to the
  * 'orderChannel'. The channel reference is configured in the "cafe" bean

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

@@ -31,9 +31,8 @@ public class Delivery {
 	private int orderNumber;
 
 
-
 	public Delivery(List<Drink> deliveredDrinks) {
-		assert (deliveredDrinks.size() > 0);
+		assert(deliveredDrinks.size() > 0);
         this.deliveredDrinks = deliveredDrinks;
 		this.orderNumber = deliveredDrinks.get(0).getOrderNumber();
     }
@@ -58,4 +57,5 @@ public class Delivery {
 		buffer.append(SEPARATOR + "\n");
 		return buffer.toString();
 	}
+
 }

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.

org.springframework.integration.samples/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="hotDrinks", 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="coldDrinks", 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;
+	}
+
+}

org.springframework.integration.samples/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);
+		}
+	}
+
+}

org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/DeliveryAssembler.java

@@ -14,12 +14,14 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.samples.cafe;
+package org.springframework.integration.samples.cafe.annotation;
 
 import java.util.List;
 
 import org.springframework.integration.annotation.Aggregator;
 import org.springframework.integration.annotation.MessageEndpoint;
+import org.springframework.integration.samples.cafe.Delivery;
+import org.springframework.integration.samples.cafe.Drink;
 
 /**
  * @author Marius Bogoevici
@@ -27,7 +29,7 @@ import org.springframework.integration.annotation.MessageEndpoint;
 @MessageEndpoint
 public class DeliveryAssembler {
 
-    @Aggregator(inputChannel = "preparedDrinks", outputChannel = "deliveries")
+    @Aggregator(inputChannel = "preparedDrinks", outputChannel = "deliveries", timeout = 5 * 60 * 1000)
     public Delivery prepareDelivery(List<Drink> drinks) {
         return new Delivery(drinks);
     }

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.
@@ -14,10 +14,11 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.samples.cafe;
+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

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.
@@ -14,12 +14,14 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.samples.cafe;
+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

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

@@ -13,34 +13,25 @@
 	<message-bus/>
 	<annotation-driven/>
 
-	<context:component-scan base-package="org.springframework.integration.samples.cafe"/>
+	<context:component-scan base-package="org.springframework.integration.samples.cafe.annotation"/>
 
 	<channel id="orders"/>
 	<channel id="drinks"/>
 
 	<channel id="coldDrinks">
-		<queue capacity="100"/>
+		<queue capacity="10"/>
 	</channel>
 
 	<channel id="hotDrinks">
-		<queue capacity="100"/>
+		<queue capacity="10"/>
 	</channel>
 
     <channel id="preparedDrinks"/>
-    <channel id="deliveries"/>
-
-	<service-activator input-channel="coldDrinks" ref="barista" method="prepareColdDrink" output-channel="preparedDrinks"/>
-
-	<service-activator input-channel="hotDrinks" ref="barista" method="prepareHotDrink" output-channel="preparedDrinks"/>
-
-	<service-activator input-channel="deliveries" ref="waiter" method="serve"/>	
 
 	<beans:bean id="cafe" class="org.springframework.integration.samples.cafe.Cafe">
 		<beans:property name="orderChannel" ref="orders"/>
 	</beans:bean>
-	
-    <channel-adapter channel="deliveries" target="deliveryOutput"/>
 
-    <console-target id="deliveryOutput"/>
+	<stdout-channel-adapter id="deliveries"/>
 	
 </beans:beans>

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.
@@ -14,17 +14,17 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.samples.cafe;
+package org.springframework.integration.samples.cafe.xml;
 
 import java.util.concurrent.atomic.AtomicInteger;
 
-import org.springframework.stereotype.Component;
+import org.springframework.integration.samples.cafe.Drink;
+import org.springframework.integration.samples.cafe.OrderItem;
 
 /**
  * @author Mark Fisher
  * @author Marius Bogoevici
  */
-@Component
 public class Barista {
 
 	private long hotDrinkDelay = 5000;

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2007 the original author or authors.
+ * 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.
@@ -14,18 +14,20 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.samples.cafe;
+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") or configured with annotations (such as the
- * OrderSplitter, DrinkRouter, and Barista classes).
+ * ("cafeDemo.xml").
  * 
  * @author Mark Fisher
  * @author Marius Bogoevici

org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/xml/DeliveryAssembler.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 DeliveryAssembler {
+
+    public Delivery prepareDelivery(List<Drink> drinks) {
+        return new Delivery(drinks);
+    }
+
+}

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

@@ -14,18 +14,17 @@
  * limitations under the License.
  */
 
-package org.springframework.integration.samples.cafe;
+package org.springframework.integration.samples.cafe.xml;
 
-import org.springframework.stereotype.Component;
+import org.springframework.integration.samples.cafe.OrderItem;
 
 /**
- * @author Marius Bogoevici
+ * @author Mark Fisher
  */
-@Component
-public class Waiter {
+public class DrinkRouter {
 
-	public void serve(Delivery delivery) {
-		System.out.println("\nDelivering: \n" + delivery);
+	public String resolveOrderItemChannel(OrderItem orderItem) {
+		return (orderItem.isIced()) ? "coldDrinks" : "hotDrinks";
 	}
 
 }

org.springframework.integration.samples/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.getDrinks();
+	}
+
+}

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

@@ -0,0 +1,46 @@
+<?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"
+	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">
+
+	<message-bus/>
+
+	<channel id="orders"/>
+	<splitter input-channel="orders" ref="orderSplitter" method="split" output-channel="drinks"/>
+
+	<channel id="drinks"/>
+	<router input-channel="drinks" ref="drinkRouter" method="resolveOrderItemChannel"/>
+
+	<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" ref="deliveryAssembler" method="prepareDelivery" output-channel="deliveries"/>
+
+	<stdout-channel-adapter id="deliveries"/>
+
+	<beans:bean id="cafe" class="org.springframework.integration.samples.cafe.Cafe">
+		<beans:property name="orderChannel" ref="orders"/>
+	</beans:bean>
+
+	<beans:bean id="orderSplitter" class="org.springframework.integration.samples.cafe.xml.OrderSplitter"/>
+
+	<beans:bean id="drinkRouter" class="org.springframework.integration.samples.cafe.xml.DrinkRouter"/>
+
+	<beans:bean id="barista" class="org.springframework.integration.samples.cafe.xml.Barista"/>
+
+	<beans:bean id="deliveryAssembler" class="org.springframework.integration.samples.cafe.xml.DeliveryAssembler"/>
+
+</beans:beans>