Changed emit_log.go to handle multiple command line args

Changed receive_logs.go to declare the Exchange so that if it is run
before emit_log it will not panic.

Author: mandolyte

go/emit_log.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"log"
 	"os"
+	"strings"
 
 	"github.com/streadway/amqp"
 )
@@ -51,11 +52,11 @@ func main() {
 }
 
 func bodyFrom(args []string) string {
-	var body string
+	var s string
 	if (len(args) < 2) || os.Args[1] == "" {
-		body = "hello"
+		s = "hello"
 	} else {
-		body = os.Args[1]
+		s = strings.Join(args[1:], " ")
 	}
-	return body
+	return s
 }

go/receive_logs.go

@@ -23,6 +23,17 @@ func main() {
 	failOnError(err, "Failed to open a channel")
 	defer ch.Close()
 
+	err = ch.ExchangeDeclare(
+		"logs",   // name
+		"fanout", // type
+		true,     // durable
+		false,    // auto-deleted
+		false,    // internal
+		false,    // no-wait
+		nil,      // arguments
+	)
+	failOnError(err, "Failed to declare an exchange")
+
 	q, err := ch.QueueDeclare(
 		"",    // name
 		false, // durable