diff options
Diffstat (limited to 'ANR-App/src/main/java/org/onap/ranapp/WebclientApplication.java')
-rw-r--r-- | ANR-App/src/main/java/org/onap/ranapp/WebclientApplication.java | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/ANR-App/src/main/java/org/onap/ranapp/WebclientApplication.java b/ANR-App/src/main/java/org/onap/ranapp/WebclientApplication.java new file mode 100644 index 0000000..e63c141 --- /dev/null +++ b/ANR-App/src/main/java/org/onap/ranapp/WebclientApplication.java @@ -0,0 +1,33 @@ +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(); + } +} |