From 0c361b9ed7c1031d4751e7fcb8b80d9dd7b8ee89 Mon Sep 17 00:00:00 2001 From: vitalykutsenko Date: Wed, 31 May 2023 19:42:36 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9F=D1=80=D0=B8=D0=BC=D0=B5=D1=80=D1=8B=20?= =?UTF-8?q?=D0=BA=20=D0=B7=D0=B0=D0=BD=D1=8F=D1=82=D0=B8=D1=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 2023-01/spring-31/.gitignore | 24 ++++++++ 2023-01/spring-31/pom.xml | 18 ++++++ 2023-01/spring-31/spring-31-exercise/pom.xml | 38 ++++++++++++ .../java/ru/otus/spring/integration/App.java | 16 +++++ .../integration/config/IntegrationConfig.java | 33 ++++++++++ .../otus/spring/integration/domain/Food.java | 15 +++++ .../spring/integration/domain/OrderItem.java | 14 +++++ .../integration/services/CafeGateway.java | 12 ++++ .../integration/services/KitchenService.java | 9 +++ .../services/KitchenServiceImpl.java | 25 ++++++++ .../integration/services/OrderService.java | 5 ++ .../services/OrderServiceImpl.java | 40 ++++++++++++ .../src/main/resources/application.yml | 0 2023-01/spring-31/spring-31-solution/pom.xml | 39 ++++++++++++ .../java/ru/otus/spring/integration/App.java | 17 ++++++ .../integration/config/IntegrationConfig.java | 41 +++++++++++++ .../otus/spring/integration/domain/Food.java | 15 +++++ .../spring/integration/domain/OrderItem.java | 14 +++++ .../integration/services/CafeGateway.java | 16 +++++ .../integration/services/KitchenService.java | 9 +++ .../services/KitchenServiceImpl.java | 25 ++++++++ .../integration/services/OrderService.java | 5 ++ .../services/OrderServiceImpl.java | 61 +++++++++++++++++++ 23 files changed, 491 insertions(+) create mode 100644 2023-01/spring-31/.gitignore create mode 100644 2023-01/spring-31/pom.xml create mode 100644 2023-01/spring-31/spring-31-exercise/pom.xml create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/App.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/Food.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/OrderItem.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/CafeGateway.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenService.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderService.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java create mode 100644 2023-01/spring-31/spring-31-exercise/src/main/resources/application.yml create mode 100644 2023-01/spring-31/spring-31-solution/pom.xml create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/App.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/Food.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/OrderItem.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/CafeGateway.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenService.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderService.java create mode 100644 2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java diff --git a/2023-01/spring-31/.gitignore b/2023-01/spring-31/.gitignore new file mode 100644 index 00000000..4ea52072 --- /dev/null +++ b/2023-01/spring-31/.gitignore @@ -0,0 +1,24 @@ +target/ + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### IntelliJ IDEA ### +.idea +*.iws +*.iml +*.ipr + +### NetBeans ### +/nbproject/private/ +/build/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ diff --git a/2023-01/spring-31/pom.xml b/2023-01/spring-31/pom.xml new file mode 100644 index 00000000..91a2874a --- /dev/null +++ b/2023-01/spring-31/pom.xml @@ -0,0 +1,18 @@ + + + 4.0.0 + + ru.otus + spring-31 + 1.0 + + pom + + + spring-31-exercise + spring-31-solution + + + diff --git a/2023-01/spring-31/spring-31-exercise/pom.xml b/2023-01/spring-31/spring-31-exercise/pom.xml new file mode 100644 index 00000000..f61dbede --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/pom.xml @@ -0,0 +1,38 @@ + + + 4.0.0 + + ru.otus + spring-31-exercise + 1.0-SNAPSHOT + + + org.springframework.boot + spring-boot-starter-parent + 2.7.8 + + + + + + org.springframework.boot + spring-boot-starter-integration + + + org.apache.commons + commons-lang3 + 3.7 + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/App.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/App.java new file mode 100644 index 00000000..14058f97 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/App.java @@ -0,0 +1,16 @@ +package ru.otus.spring.integration; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.ConfigurableApplicationContext; +import ru.otus.spring.integration.services.OrderService; + + +@SpringBootApplication +public class App { + public static void main(String[] args) { + ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args); + OrderService orderService = ctx.getBean(OrderService.class); + orderService.startGenerateOrdersLoop(); + } +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java new file mode 100644 index 00000000..56615d51 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java @@ -0,0 +1,33 @@ +package ru.otus.spring.integration.config; + +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.integration.channel.PublishSubscribeChannel; +import org.springframework.integration.channel.QueueChannel; +import org.springframework.integration.dsl.IntegrationFlow; +import org.springframework.integration.dsl.IntegrationFlows; +import org.springframework.integration.dsl.MessageChannels; + +@Configuration +public class IntegrationConfig { + @Bean + public QueueChannel itemsChannel() { + return MessageChannels.queue(10).get(); + } + + @Bean + public PublishSubscribeChannel foodChannel() { + return MessageChannels.publishSubscribe().get(); + } + + // TODO: create default poller + + @Bean + public IntegrationFlow cafeFlow() { + return IntegrationFlows.from("itemsChannel") + // TODO: cook OrderItem in the kitchen + // TODO*: add splitter and aggregator + // TODO: forward it to the publish subscriber channel + .get(); + } +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/Food.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/Food.java new file mode 100644 index 00000000..16d8e9c6 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/Food.java @@ -0,0 +1,15 @@ +package ru.otus.spring.integration.domain; + + +public class Food { + + private final String name; + + public Food(String name) { + this.name = name; + } + + public String getName() { + return name; + } +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/OrderItem.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/OrderItem.java new file mode 100644 index 00000000..68612e96 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/domain/OrderItem.java @@ -0,0 +1,14 @@ +package ru.otus.spring.integration.domain; + +public class OrderItem { + + private final String itemName; + + public OrderItem(String itemName) { + this.itemName = itemName; + } + + public String getItemName() { + return itemName; + } +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/CafeGateway.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/CafeGateway.java new file mode 100644 index 00000000..58c24077 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/CafeGateway.java @@ -0,0 +1,12 @@ +package ru.otus.spring.integration.services; + + +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +// TODO: add messaging gateway annotation +public interface CafeGateway { + + // TODO: add gateway annotation with required channels + Food process(OrderItem orderItem); +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenService.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenService.java new file mode 100644 index 00000000..2ae92af2 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenService.java @@ -0,0 +1,9 @@ +package ru.otus.spring.integration.services; + +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +public interface KitchenService { + + Food cook(OrderItem orderItem); +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java new file mode 100644 index 00000000..8a01a914 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java @@ -0,0 +1,25 @@ +package ru.otus.spring.integration.services; + +import org.springframework.stereotype.Service; +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +@Service +public class KitchenServiceImpl implements KitchenService { + + @Override + public Food cook(OrderItem orderItem) { + System.out.println("Cooking " + orderItem.getItemName()); + delay(); + System.out.println("Cooking " + orderItem.getItemName() + " done"); + return new Food(orderItem.getItemName()); + } + + private static void delay() { + try { + Thread.sleep(3000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderService.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderService.java new file mode 100644 index 00000000..c5da0ac9 --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderService.java @@ -0,0 +1,5 @@ +package ru.otus.spring.integration.services; + +public interface OrderService { + void startGenerateOrdersLoop(); +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java new file mode 100644 index 00000000..efb0bede --- /dev/null +++ b/2023-01/spring-31/spring-31-exercise/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java @@ -0,0 +1,40 @@ +package ru.otus.spring.integration.services; + +import org.apache.commons.lang3.RandomUtils; +import org.springframework.stereotype.Service; +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +@Service +public class OrderServiceImpl implements OrderService { + private static final String[] MENU = {"coffee", "tea", "smoothie", "whiskey", "beer", "cola", "water"}; + + private final CafeGateway cafe; + + public OrderServiceImpl(CafeGateway cafe) { + this.cafe = cafe; + } + + public void startGenerateOrdersLoop() { + for (int i = 0; i < 10; i++) { + delay(); + + OrderItem orderItem = generateOrderItem(); + System.out.println("New orderItem: " + orderItem.getItemName()); + Food food = cafe.process(orderItem); + System.out.println("Ready food: " + food.getName()); + } + } + + private static OrderItem generateOrderItem() { + return new OrderItem(MENU[RandomUtils.nextInt(0, MENU.length)]); + } + + private void delay() { + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } +} diff --git a/2023-01/spring-31/spring-31-exercise/src/main/resources/application.yml b/2023-01/spring-31/spring-31-exercise/src/main/resources/application.yml new file mode 100644 index 00000000..e69de29b diff --git a/2023-01/spring-31/spring-31-solution/pom.xml b/2023-01/spring-31/spring-31-solution/pom.xml new file mode 100644 index 00000000..cebe4933 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/pom.xml @@ -0,0 +1,39 @@ + + + 4.0.0 + + ru.otus + spring-31-solution + 1.0-SNAPSHOT + + + org.springframework.boot + spring-boot-starter-parent + 2.7.8 + + + + + + org.springframework.boot + spring-boot-starter-integration + + + + org.apache.commons + commons-lang3 + 3.7 + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/App.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/App.java new file mode 100644 index 00000000..79be8664 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/App.java @@ -0,0 +1,17 @@ +package ru.otus.spring.integration; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.ConfigurableApplicationContext; +import ru.otus.spring.integration.services.OrderService; + + +@SpringBootApplication +public class App { + + public static void main(String[] args) { + ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args); + OrderService orderService = ctx.getBean(OrderService.class); + orderService.startGenerateOrdersLoop(); + } +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java new file mode 100644 index 00000000..ed5471f4 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/config/IntegrationConfig.java @@ -0,0 +1,41 @@ +package ru.otus.spring.integration.config; + +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.integration.channel.PublishSubscribeChannel; +import org.springframework.integration.channel.QueueChannel; +import org.springframework.integration.dsl.IntegrationFlow; +import org.springframework.integration.dsl.IntegrationFlows; +import org.springframework.integration.dsl.MessageChannels; +import org.springframework.integration.dsl.Pollers; +import org.springframework.integration.scheduling.PollerMetadata; +import ru.otus.spring.integration.services.KitchenServiceImpl; + +@Configuration +public class IntegrationConfig { + + @Bean + public QueueChannel itemsChannel() { + return MessageChannels.queue(10).get(); + } + + @Bean + public PublishSubscribeChannel foodChannel() { + return MessageChannels.publishSubscribe().get(); + } + + @Bean(name = PollerMetadata.DEFAULT_POLLER) + public PollerMetadata poller() { + return Pollers.fixedRate(100).maxMessagesPerPoll(2).get(); + } + + @Bean + public IntegrationFlow cafeFlow(KitchenServiceImpl kitchenService) { + return IntegrationFlows.from(itemsChannel()) + .split() + .handle(kitchenService, "cook") + .aggregate() + .channel(foodChannel()) + .get(); + } +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/Food.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/Food.java new file mode 100644 index 00000000..16d8e9c6 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/Food.java @@ -0,0 +1,15 @@ +package ru.otus.spring.integration.domain; + + +public class Food { + + private final String name; + + public Food(String name) { + this.name = name; + } + + public String getName() { + return name; + } +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/OrderItem.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/OrderItem.java new file mode 100644 index 00000000..68612e96 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/domain/OrderItem.java @@ -0,0 +1,14 @@ +package ru.otus.spring.integration.domain; + +public class OrderItem { + + private final String itemName; + + public OrderItem(String itemName) { + this.itemName = itemName; + } + + public String getItemName() { + return itemName; + } +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/CafeGateway.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/CafeGateway.java new file mode 100644 index 00000000..85cae973 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/CafeGateway.java @@ -0,0 +1,16 @@ +package ru.otus.spring.integration.services; + + +import org.springframework.integration.annotation.Gateway; +import org.springframework.integration.annotation.MessagingGateway; +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +import java.util.Collection; + +@MessagingGateway +public interface CafeGateway { + + @Gateway(requestChannel = "itemsChannel", replyChannel = "foodChannel") + Collection process(Collection orderItem); +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenService.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenService.java new file mode 100644 index 00000000..2ae92af2 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenService.java @@ -0,0 +1,9 @@ +package ru.otus.spring.integration.services; + +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +public interface KitchenService { + + Food cook(OrderItem orderItem); +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java new file mode 100644 index 00000000..8a01a914 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/KitchenServiceImpl.java @@ -0,0 +1,25 @@ +package ru.otus.spring.integration.services; + +import org.springframework.stereotype.Service; +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +@Service +public class KitchenServiceImpl implements KitchenService { + + @Override + public Food cook(OrderItem orderItem) { + System.out.println("Cooking " + orderItem.getItemName()); + delay(); + System.out.println("Cooking " + orderItem.getItemName() + " done"); + return new Food(orderItem.getItemName()); + } + + private static void delay() { + try { + Thread.sleep(3000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderService.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderService.java new file mode 100644 index 00000000..c5da0ac9 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderService.java @@ -0,0 +1,5 @@ +package ru.otus.spring.integration.services; + +public interface OrderService { + void startGenerateOrdersLoop(); +} diff --git a/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java new file mode 100644 index 00000000..e0364b17 --- /dev/null +++ b/2023-01/spring-31/spring-31-solution/src/main/java/ru/otus/spring/integration/services/OrderServiceImpl.java @@ -0,0 +1,61 @@ +package ru.otus.spring.integration.services; + +import org.apache.commons.lang3.RandomUtils; +import org.springframework.stereotype.Service; +import ru.otus.spring.integration.domain.Food; +import ru.otus.spring.integration.domain.OrderItem; + +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; +import java.util.concurrent.ForkJoinPool; +import java.util.stream.Collectors; + +@Service +public class OrderServiceImpl implements OrderService { + private static final String[] MENU = {"coffee", "tea", "smoothie", "whiskey", "beer", "cola", "water"}; + + private final CafeGateway cafe; + + public OrderServiceImpl(CafeGateway cafe) { + this.cafe = cafe; + } + + public void startGenerateOrdersLoop() { + ForkJoinPool pool = ForkJoinPool.commonPool(); + for (int i = 0; i < 10; i++) { + delay(); + pool.execute(() -> { + Collection items = generateOrderItems(); + 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(","))); + }); + } + } + + private static OrderItem generateOrderItem() { + return new OrderItem(MENU[RandomUtils.nextInt(0, MENU.length)]); + } + + private static Collection generateOrderItems() { + List items = new ArrayList<>(); + for (int i = 0; i < RandomUtils.nextInt(1, 5); ++i) { + items.add(generateOrderItem()); + } + return items; + } + + private void delay() { + try { + Thread.sleep(7000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + + } +}