From 22e5a2b6abe6d3fa8342dc0e5273792f74e3c0bc Mon Sep 17 00:00:00 2001
From: kataus <kataus@gmail.com>
Date: Wed, 4 Dec 2019 18:27:25 +0300
Subject: [PATCH] =?UTF-8?q?=D0=90=D0=BA=D1=82=D1=83=D0=B0=D0=BB=D0=B8?=
 =?UTF-8?q?=D0=B7=D0=B0=D1=86=D0=B8=D1=8F=20=D0=BF=D1=80=D0=B8=D0=BC=D0=B5?=
 =?UTF-8?q?=D1=80=D0=BE=D0=B2=20=D0=BD=D0=B0=20=D0=B7=D0=B0=D0=BD=D1=8F?=
 =?UTF-8?q?=D1=82=D0=B8=D0=B5=2026=20(SI:=20Endpoints=20=D0=B8=20Flow=20Co?=
 =?UTF-8?q?mponents)=20=D0=B4=D0=BB=D1=8F=20=D0=B3=D1=80=D1=83=D0=BF=D0=BF?=
 =?UTF-8?q?=D1=8B=202019-08?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/ru/otus/spring/integration/App.java  | 19 ++++---------------
 .../java/ru/otus/spring/integration/Cafe.java |  3 +--
 2 files changed, 5 insertions(+), 17 deletions(-)

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<OrderItem> items = generateOrderItems();
+            OrderItem items = generateOrderItem();
             System.out.println( "New orderItems: " +
-                    items.stream().map( OrderItem::getItemName )
-                            .collect( Collectors.joining( "," ) ) );
-            Collection<Food> 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<OrderItem> generateOrderItems() {
-        List<OrderItem> 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<Food> process( Collection<OrderItem> orderItem );
+    Food process( OrderItem orderItem);
 }