diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/Barista.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/Barista.java
index 81bcbde014..e369771215 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/Barista.java
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/Barista.java
@@ -26,7 +26,7 @@ import org.springframework.stereotype.Component;
@Component
public class Barista {
- private long hotDrinkDelay = 2000;
+ private long hotDrinkDelay = 5000;
private long coldDrinkDelay = 1000;
@@ -46,19 +46,21 @@ public class Barista {
public void prepareHotDrink(Drink drink) {
try {
Thread.sleep(this.hotDrinkDelay);
+ System.out.println(Thread.currentThread().getName()
+ + " prepared hot drink #" + hotDrinkCounter.incrementAndGet() + ": " + drink);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
- System.out.println("prepared hot drink #" + hotDrinkCounter.incrementAndGet() + ": " + drink);
}
public void prepareColdDrink(Drink drink) {
try {
Thread.sleep(this.coldDrinkDelay);
+ System.out.println(Thread.currentThread().getName()
+ + " prepared cold drink #" + coldDrinkCounter.incrementAndGet() + ": " + drink);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
- System.out.println("prepared cold drink #" + coldDrinkCounter.incrementAndGet() + ": " + drink);
}
}
diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/cafeDemo.xml b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/cafeDemo.xml
index e1ec27910c..9a63405d42 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/cafeDemo.xml
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/cafeDemo.xml
@@ -21,7 +21,11 @@
-
+
+
+
+
+