summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--main.go10
1 files changed, 8 insertions, 2 deletions
diff --git a/main.go b/main.go
index 63b1a4d..e38169a 100644
--- a/main.go
+++ b/main.go
@@ -6,6 +6,8 @@ import (
"fmt"
"log"
"log/slog"
+ "os"
+ "os/signal"
"runtime"
"time"
@@ -72,6 +74,10 @@ func main() {
log.Fatalf("Error reading from Jetstream: %v", err)
}
- // Keep the program running
- select {}
+ // Wait for interrupt signal to gracefully shut down
+ interrupt := make(chan os.Signal, 1)
+ signal.Notify(interrupt, os.Interrupt)
+ <-interrupt
+
+ log.Println("Shutting down...")
}