diff --git a/2019-08/spring-26/src/main/java/ru/otus/spring/integration/App.java b/2019-08/spring-26/src/main/java/ru/otus/spring/integration/App.java index c89bbe00..2ec8b58e 100644 --- a/2019-08/spring-26/src/main/java/ru/otus/spring/integration/App.java +++ b/2019-08/spring-26/src/main/java/ru/otus/spring/integration/App.java @@ -60,25 +60,14 @@ public class App { while ( true ) { Thread.sleep( 1000 ); - Collection items = generateOrderItems(); + OrderItem items = generateOrderItem(); System.out.println( "New orderItems: " + - items.stream().map( OrderItem::getItemName ) - .collect( Collectors.joining( "," ) ) ); - Collection food = cafe.process( items ); - System.out.println( "Ready food: " + food.stream() - .map( Food::getName ) - .collect( Collectors.joining( "," ) ) ); + items.getItemName() ); + Food food = cafe.process( items ); + System.out.println( "Ready food: " + food.getName() ); } } - private static Collection generateOrderItems() { - List items = new ArrayList<>(); - for ( int i = 0; i < RandomUtils.nextInt( 1, 5 ); ++ i ) { - items.add( generateOrderItem() ); - } - return items; - } - private static OrderItem generateOrderItem() { return new OrderItem( MENU[ RandomUtils.nextInt( 0, MENU.length ) ] ); } diff --git a/2019-08/spring-26/src/main/java/ru/otus/spring/integration/Cafe.java b/2019-08/spring-26/src/main/java/ru/otus/spring/integration/Cafe.java index 2f1a7733..180de97b 100644 --- a/2019-08/spring-26/src/main/java/ru/otus/spring/integration/Cafe.java +++ b/2019-08/spring-26/src/main/java/ru/otus/spring/integration/Cafe.java @@ -1,6 +1,5 @@ package ru.otus.spring.integration; - import ru.otus.spring.integration.domain.Food; import ru.otus.spring.integration.domain.OrderItem; @@ -10,5 +9,5 @@ import java.util.Collection; public interface Cafe { // TODO: add gateway annotation with required channels - Collection process( Collection orderItem ); + Food process( OrderItem orderItem); }