x/box-o-sand
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Almost kinda there...

Browse Source
This commit is contained in:
Dan Buch 2012-11-14 22:27:46 -05:00
parent 1991c87ba9
commit f1c4f20058
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
sylvilagus/go/src/meatballhat.com/sylvilagus-chapter02-hello-world-consumer/main.go
View File

@ -26,8 +26,29 @@ func main() {
log.Fatal("Failed to declare exchange!: ", err)
}
_, err = channel.QueueDeclare("hello-queue", true, false, false, false, nil)
if err != nil {
log.Fatal("Failed to declare queue!: ", err)
}
err = channel.QueueBind("hello-queue", "hola", "hello-exchange", false, nil)
if err != nil {
log.Fatal("Failed to bind to queue!: ", err)
}
hellos, err := channel.Consume("hello-queue", "hello-consumer", false, false, false, false, nil)
if err != nil {
log.Fatal("Failed to start consuming!:", err)
}
quit := make(chan bool)
go func() {
for hello := range hellos {
log.Println("hello ->", hello)
hello.Ack(false)
}
}()
<-quit
}