Refactor error handling

go/receive.go

@@ -4,21 +4,23 @@ import (
 	"github.com/streadway/amqp"
 	"log"
 	"os"
+	"fmt"
 )
 
-func main() {
-	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
+func failOnError(err error, msg string) {
 	if err != nil {
-		log.Fatalf("Dial: %s", err)
-		return
+		log.Fatalf("%s: %s", msg, err)
+		panic(fmt.Sprintf("%s: %s", msg, err))
 	}
+}
+
+func main() {
+	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
+	failOnError(err, "Failed to connect to RabbitMQ")
 	defer conn.Close()
 
 	ch, err := conn.Channel()
-	if err != nil {
-		log.Fatalf("Channel: %s", err)
-		return
-	}
+	failOnError(err, "Failed to open a channel")
 
 	defer ch.Close()
 
@@ -30,12 +32,10 @@ func main() {
 		false,   // noWait
 		nil,     // arguments
 	)
-	if err != nil {
-		log.Fatalf("Queue Declare: %s", err)
-		return
-	}
+	failOnError(err, "Failed to declare a queue")
 
 	msgs, err := ch.Consume(q.Name, "", true, false, false, false, nil)
+	failOnError(err, "Failed to register a consumer")
 
 	done := make(chan bool)
 	var d amqp.Delivery

go/send.go

@@ -4,21 +4,23 @@ import (
 	"github.com/streadway/amqp"
 	"log"
 	"os"
+	"fmt"
 )
 
-func main() {
-	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
+func failOnError(err error, msg string) {
 	if err != nil {
-		log.Fatalf("Dial: %s", err)
-		return
+		log.Fatalf("%s: %s", msg, err)
+		panic(fmt.Sprintf("%s: %s", msg, err))
 	}
+}
+
+func main() {
+	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
+	failOnError(err, "Failed to connect to RabbitMQ")
 	defer conn.Close()
 
 	ch, err := conn.Channel()
-	if err != nil {
-		log.Fatalf("Channel: %s", err)
-		return
-	}
+	failOnError(err, "Failed to open a channel")
 
 	defer ch.Close()
 
@@ -30,10 +32,7 @@ func main() {
 		false,   // noWait
 		nil,     // arguments
 	)
-	if err != nil {
-		log.Fatalf("Queue Declare: %s", err)
-		return
-	}
+	failOnError(err, "Failed to declare a queue")
 
 	body := "hello"
 	err = ch.Publish(
@@ -45,11 +44,7 @@ func main() {
 			ContentType:     "text/plain",
 			Body:            []byte(body),
 		})
-
-	if err != nil {
-		log.Fatalf("Exchange Publish: %s", err)
-		return
-	}
+	failOnError(err, "Failed to publish a message")
 
 	os.Exit(0)
 }