rabbitmq-tutorials/go
2014-08-25 23:24:38 -04:00
..
.gitignore .gitignore for Go tutorials 2013-10-17 01:10:14 +04:00
emit_log_direct.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
emit_log_topic.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
emit_log.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
new_task.go Go: Added missing import "os" 2014-08-25 23:24:38 -04:00
README.md Added Tutorial 6 code for Go. 2014-08-18 21:29:22 -04:00
receive_logs_direct.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
receive_logs_topic.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
receive_logs.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
receive.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
rpc_client.go Added Tutorial 6 code for Go. 2014-08-18 21:29:22 -04:00
rpc_server.go Added Tutorial 6 code for Go. 2014-08-18 21:29:22 -04:00
send.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00
worker.go Improved, fixed bug, and cleaned up code for Go. 2014-08-18 21:29:50 -04:00

Go code for RabbitMQ tutorials

Here you can find Go code examples from RabbitMQ tutorials.

Requirements

To run this code you need Go RabbitMQ client:

go get github.com/streadway/amqp

Code

Code examples are executed via go run:

Tutorial one: "Hello World!":

go run send.go
go run receive.go

Tutorial two: Work Queues:

go run new_task.go hello world
go run worker.go

Tutorial three: Publish/Subscribe

go run receive_logs.go
go run emit_log.go hello world

Tutorial four: Routing

go run receive_logs_direct.go info warn
go run emit_log_direct.go warn "a warning"

Tutorial five: Topics

go run receive_logs_topic.go info warn
go run emit_log_topic.go warn "a warning"

Tutorial six: RPC

go run rpc_server.go
go run rpc_client.go 10

To learn more, see Go RabbitMQ client.