import java.util.HashMap;
import java.util.Map;
-import java.util.concurrent.ExecutionException;
@RestController
@RequiredArgsConstructor
public class DriverController
{
+ private final EndlessConsumer consumer;
+
+
@PostMapping("start")
public void start()
{
+ consumer.start();
}
@PostMapping("stop")
- public void stop() throws ExecutionException, InterruptedException
+ public void stop()
{
+ consumer.stop();
}
@GetMapping("seen")