diff --git a/firehose/server/server.go b/firehose/server/server.go index 22a3291..a2f8099 100644 --- a/firehose/server/server.go +++ b/firehose/server/server.go @@ -165,6 +165,9 @@ func (s *Server) Launch() { wg.Add(1) go func() { server.Launch(server.listenAddr) + for _, srv := range s.servers { + srv.Shutdown(0) // immediately shutdown all other servers when one terminates, in case a single one failed + } wg.Done() }() }