@ -2,6 +2,7 @@ package main
import (
"flag"
"fmt"
"log"
)
@ -16,6 +17,7 @@ var (
func main() {
flag.Parse()
fmt.Printf("Connecting to %v...\n", *connUri)
conn, err := amqp.Dial(*connUri)
defer conn.Close()