(This presentation made with Landslide.)
Integration of internal and external systems
Financial and supply-chain data
Order fulfillment process
Inventory
Decoupling systems
Developer happiness
Data integrity
Message durability and routing
Copious language bindings
Clustering and high availibity support
Flexible messaging patterns
Writes 10 messages to the example exchange
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
connection, _ := amqp.Dial(amqpURI) channel, _ := connection.Channel() for i := 0; i < 10; i++ { channel.Publish( "example", //exchange "hello.world", //routingKey false, false, amqp.Publishing{ Headers: amqp.Table{}, ContentType: "text/plain", ContentEncoding: "UTF-8", Body: []byte("Hi"), DeliveryMode: amqp.Transient, Priority: 0, }, ) }
Reads from the example_queue forever
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
c.conn, _ = amqp.Dial(amqpURI) c.channel, _ = c.conn.Channel() deliveries, _ := c.channel.Consume( "example_queue", //queue c.tag, false, false, false, false, nil) for d := range deliveries { log.Printf("got %s", d.Body) }
RabbitMQ
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
,_ ,_ (\/) _, _, | '. '. \/ .' .' | \ \ \ / / / '.__\_|_ _|_/__.' /` '. .' `\ / ^ ) ( ^ \ / __.' '.__ \ .' (_ _) '. .' \'-._ _.-'/ '. / '.__)(__.' \ ; .-. '. .' .-. ; /`| / '._)(_.' \ |`\ | \ /--. .--\ / | '--'\ '-.__) (__.-' /'--' jgs )_____) (______(
