Added a @CorrelationStrategy for illustration purposes.
This commit is contained in:
@@ -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();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user