diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/Waiter.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/Waiter.java
index 0d27bbbf07..8602d676ef 100644
--- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/Waiter.java
+++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/cafe/annotation/Waiter.java
@@ -19,6 +19,7 @@ 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;
@@ -33,5 +34,10 @@ public class Waiter {
     public Delivery prepareDelivery(List<Drink> drinks) {
         return new Delivery(drinks);
     }
-
+    
+    @CorrelationStrategy
+    public int correlateByOrderNumber(Drink drink) {
+    	return drink.getOrderNumber();
+    }
+    
 }