2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright 2019 China Mobile
6 *=================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
20 package org.onap.datalake.feeder.controller;
22 import java.io.IOException;
24 import org.onap.datalake.feeder.service.PullService;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
27 import org.springframework.beans.factory.annotation.Autowired;
28 import org.springframework.http.MediaType;
29 import org.springframework.web.bind.annotation.RequestMapping;
30 import org.springframework.web.bind.annotation.RestController;
33 * This controller controls DL data feeder.
40 @RequestMapping(value = "/pull", produces = { MediaType.TEXT_PLAIN_VALUE })
41 public class PullController {
43 private final Logger log = LoggerFactory.getLogger(this.getClass());
46 private PullService pullService;
49 * @return message that application is started
52 @RequestMapping("/start")
53 public String start() throws IOException {
54 log.info("DataLake feeder starting to pull data from DMaaP...");
56 return "DataLake feeder is running.";
60 * @return message that application stop process is triggered
62 @RequestMapping("/stop")
63 public String stop() {
64 pullService.shutdown();
65 log.info("DataLake feeder is stopped.");
66 return "DataLake feeder is stopped.";
69 * @return feeder status
71 @RequestMapping("/status")
72 public String status() {
73 String status = "to be impletemented";
74 log.info("senting feeder status ...");//TODO we can send what topics are monitored, how many messages are sent, etc.