return error instead of log.Fatal

neicnordic · Feb 9, 2023 · b9b6a99 · b9b6a99
1 parent 9c246a4
commit b9b6a99
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/messenger.go b/messenger.go
@@ -150,9 +150,10 @@ func (m *AMQPMessenger) createNewChannel() error {
 	confirmsChan := make(chan amqp.Confirmation, 1)
 	if err := c.Confirm(false); err != nil {
 		close(confirmsChan)
-		log.Fatalf("Channel could not be put into confirm mode: %s\n", err)
+
+		return fmt.Errorf("channel could not be put into confirm mode: %v", err)
 	}
-	log.Debugln("recconected to new channel")
+	log.Debugln("reconnected to new channel")
 	m.channel = c
 	m.confirmsChan = c.NotifyPublish(confirmsChan)