package org.onap.ranapp; import org.springframework.context.ApplicationContext; import org.onap.ranapp.kafka.client.KafkaClientRanappTopic; import org.onap.ranapp.websocket.WebsocketClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; @SpringBootApplication public class WebclientApplication { @Autowired private WebsocketClient websocketClient; @Autowired private KafkaClientRanappTopic kafkaclient; public static void main(String[] args) { SpringApplication.run(WebclientApplication.class, args); } /* *Starts the Websocket client service. @param ctx the * application context. // * // * @return the command line runner for the * Websocket client. // */ @Bean public CommandLineRunner websocketClientRunner(ApplicationContext ctx) { return args -> websocketClient.start(); } @Bean public CommandLineRunner policytopicKafkaClientRunner(ApplicationContext ctx) { return args -> kafkaclient.getRanApp_KafkaTopicnames(); } }