juplo.de Git - demos/kafka/chat/blob - src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java

   1 package de.juplo.kafka.chat.backend;
   2
   3 import de.juplo.kafka.chat.backend.domain.ChatHomeService;
   4 import de.juplo.kafka.chat.backend.implementation.StorageStrategy;
   5 import jakarta.annotation.PreDestroy;
   6 import org.springframework.beans.factory.annotation.Autowired;
   7 import org.springframework.boot.SpringApplication;
   8 import org.springframework.boot.autoconfigure.SpringBootApplication;
   9 import org.springframework.boot.autoconfigure.data.mongo.MongoReactiveDataAutoConfiguration;
  10 import org.springframework.boot.autoconfigure.data.mongo.MongoReactiveRepositoriesAutoConfiguration;
  11 import org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration;
  12 import org.springframework.web.reactive.config.CorsRegistry;
  13 import org.springframework.web.reactive.config.WebFluxConfigurer;
  14
  15
  16 @SpringBootApplication(exclude = {
  17                 MongoReactiveDataAutoConfiguration.class,
  18                 MongoReactiveRepositoriesAutoConfiguration.class,
  19                 MongoAutoConfiguration.class })
  20 public class ChatBackendApplication implements WebFluxConfigurer
  21 {
  22         @Autowired
  23         ChatBackendProperties properties;
  24         @Autowired
  25         ChatHomeService chatHomeService;
  26         @Autowired
  27         StorageStrategy storageStrategy;
  28
  29
  30         @Override
  31         public void addCorsMappings(CorsRegistry registry)
  32         {
  33                 registry
  34                                 .addMapping("/**")
  35                                 .allowedOrigins(properties.getAllowedOrigins());
  36         }
  37
  38         @PreDestroy
  39         public void onExit()
  40         {
  41                 storageStrategy
  42                                 .write(chatHomeService)
  43                                 .subscribe();
  44         }
  45
  46         public static void main(String[] args)
  47         {
  48                 SpringApplication.run(ChatBackendApplication.class, args);
  49         }
  50 }