X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Foutbox;a=blobdiff_plain;f=outbox%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Foutbox%2FApplication.java;h=678a48a59d3176275575e6e8f52ac925f2294214;hp=a63d714766ce4f3771d4424c693970c2f71d1bcf;hb=ef81f7d7d56b67a2084d1a5d3f66c5a3db8fb796;hpb=996911bbed45e0211e48976e3cb3971631361e5b

diff --git a/outbox/src/main/java/de/juplo/kafka/outbox/Application.java b/outbox/src/main/java/de/juplo/kafka/outbox/Application.java
index a63d714..678a48a 100644
--- a/outbox/src/main/java/de/juplo/kafka/outbox/Application.java
+++ b/outbox/src/main/java/de/juplo/kafka/outbox/Application.java
@@ -1,36 +1,18 @@
 package de.juplo.kafka.outbox;
 
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
-
-import java.util.concurrent.CountDownLatch;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 
 @SpringBootApplication
 @EnableConfigurationProperties(ApplicationProperties.class)
-@Slf4j
+@EnableScheduling
 public class Application
 {
   public static void main(String[] args) throws Exception
   {
     SpringApplication.run(Application.class, args);
-
-    final CountDownLatch closeLatch = new CountDownLatch(1);
-
-    Runtime
-        .getRuntime()
-        .addShutdownHook(new Thread()
-        {
-          @Override
-          public void run()
-          {
-            log.info("Closing application...");
-            closeLatch.countDown();
-          }
-        });
-
-    closeLatch.await();
   }
 }