diff options
Diffstat (limited to 'main.go')
-rw-r--r-- | main.go | 10 |
1 files changed, 8 insertions, 2 deletions
@@ -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...") } |