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

Implementing the producer side and breaking out common topology bits

Browse Source
This commit is contained in:
Dan Buch
2012-11-15 00:05:44 -05:00
parent 46933f0611
commit 3fed0c2e4e
4 changed files with 88 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -6,6 +6,7 @@ import (
import (
"github.com/streadway/amqp"
"meatballhat.com/sylvilagus"
)
func main() {
@@ -16,24 +17,9 @@ func main() {
defer connection.Close()
channel, err := connection.Channel()
channel, err := sylvilagus.CreateHelloTopology(connection)
if err != nil {
log.Fatal("Failed to get channel!: ", err)
}
err = channel.ExchangeDeclare("hello-exchange", "direct", true, false, false, false, nil)
if err != nil {
log.Fatal("Failed to declare exchange!: ", err)
}
_, err = channel.QueueDeclare("hello-queue", false, 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)
log.Fatal("Failed to build topology!: ", err)
}
hellos, err := channel.Consume("hello-queue", "hello-consumer", false, false, false, false, nil)