added dot count for fake work delay

mandolyte · mandolyte · commit 1720d85d0d80 · 2014-10-26T08:07:52.000-04:00
diff --git a/go/worker.go b/go/worker.go
@@ -57,6 +57,9 @@ func main() {
 		for d := range msgs {
 			log.Printf("Received a message: %s", d.Body)
 			d.Ack(false)
+			dot_count := bytes.Count(d.Body, []byte("."))
+			t := time.Duration(dot_count)
+			time.Sleep(t * time.Second)
 		}
 	}()
 

Original file line number	Diff line number	Diff line change
`@@ -57,6 +57,9 @@ func main() {`
`57`	`57`	`for d := range msgs {`
`58`	`58`	`log.Printf("Received a message: %s", d.Body)`
`59`	`59`	`d.Ack(false)`
	`60`	`+ dot_count := bytes.Count(d.Body, []byte("."))`
	`61`	`+ t := time.Duration(dot_count)`
	`62`	`+ time.Sleep(t * time.Second)`
`60`	`63`	`}`
`61`	`64`	`}()`
`62`	`65`