Changed emit_log.go to handle multiple command line args

mandolyte · mandolyte · commit 1b92c78a002a · 2014-10-26T18:35:00.000-04:00
Changed receive_logs.go to declare the Exchange so that if it is run
before emit_log it will not panic.
diff --git a/go/emit_log.go b/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
 }
diff --git a/go/receive_logs.go b/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

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@ import (`
`4`	`4`	`"fmt"`
`5`	`5`	`"log"`
`6`	`6`	`"os"`
	`7`	`+ "strings"`
`7`	`8`
`8`	`9`	`"github.com/streadway/amqp"`
`9`	`10`	`)`
`@@ -51,11 +52,11 @@ func main() {`
`51`	`52`	`}`
`52`	`53`
`53`	`54`	`func bodyFrom(args []string) string {`
`54`		`- var body string`
	`55`	`+ var s string`
`55`	`56`	`if (len(args) < 2) \|\| os.Args[1] == "" {`
`56`		`- body = "hello"`
	`57`	`+ s = "hello"`
`57`	`58`	`} else {`
`58`		`- body = os.Args[1]`
	`59`	`+ s = strings.Join(args[1:], " ")`
`59`	`60`	`}`
`60`		`- return body`
	`61`	`+ return s`
`61`	`62`	`}`