public
Description: AMQP client implementation in Ruby/EventMachine
Homepage: http://groups.google.com/group/ruby-amqp
Clone URL: git://github.com/tmm1/amqp.git
amqp / README
100644 129 lines (89 sloc) 5.152 kb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
Simple AMQP driver for Ruby/EventMachine
  (c) 2008 Aman Gupta (tmm1)
 
  http://github.com/tmm1/amqp
  http://rubyforge.org/projects/amqp
  http://hopper.squarespace.com/blog/2008/7/22/simple-amqp-library-for-ruby.html
  http://groups.google.com/group/ruby-amqp
  http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2008-July/001417.html
 
This library works with Ruby 1.8, Ruby 1.9, JRuby and Rubinius, and is licensed under the Ruby License.
 
This library was tested primarily with RabbitMQ, although it should be compatible with any
server implementing the AMQP 0-8 spec.
 
To use with RabbitMQ, first run the server:
 
  hg clone http://hg.rabbitmq.com/rabbitmq-codegen
  hg clone http://hg.rabbitmq.com/rabbitmq-server
  cd rabbitmq-server
  make run
 
To get started, refer to the various bundled examples:
 
  ruby examples/mq/pingpong.rb # 1-1 communication using amq.direct
  ruby examples/mq/clock.rb # 1-N communication using amq.fanout
  ruby examples/mq/stocks.rb # 1-subscriber communication using amq.topic
 
  ruby examples/mq/multiclock.rb # header based routing (new rabbitmq feature)
  ruby examples/mq/ack.rb # using ack
  ruby examples/mq/pop.rb # pop off messages one at a time
 
  ruby examples/mq/hashtable.rb # simple async rpc layer
  ruby examples/mq/primes.rb 4 # parallelized prime number generation
  ruby examples/mq/logger.rb # simple logging api
 
For more details into the lower level AMQP client API, run the simple client example:
 
  ruby examples/amqp/simple.rb # low-level AMQP api
  ruby examples/mq/internal.rb # low-level Queue/Exchange api
 
Or refer to protocol/doc.txt, which enumerates packets sent between a server and client
during a typical session, in both binary and decoded formats.
 
To run the test suite:
 
  rake spec
 
The lib/amqp/spec.rb file is generated automatically based on the AMQP specification. To generate it:
 
  rake codegen
 
This project was inspired by py-amqplib, rabbitmq, qpid and rubbyt.
Special thanks to Dmitriy Samovskiy, Ben Hood and Tony Garnock-Jones.
 
AMQP resources:
 
  Servers:
    RabbitMQ (Rabbit Technologies, Erlang/OTP, MPL) - http://rabbitmq.com
    ZeroMQ (iMatix/FastMQ/Intel, C++, GPL3) - http://www.zeromq.org
    OpenAMQ (iMatix, C, GPL2) - http://openamq.org
    ActiveMQ (Apache Foundation, Java, apache2) - http://activemq.apache.org
 
  Steve Vinoski explains AMQP in his column, Towards Integration
    http://steve.vinoski.net/pdf/IEEE-Advanced_Message_Queuing_Protocol.pdf
 
  John O'Hara on the history of AMQP
    http://www.acmqueue.org/modules.php?name=Content&pa=showpage&pid=485
 
  Dmitriy's presentation on RabbitMQ/AMQP
    http://somic-org.homelinux.org/blog/2008/07/31/slides-for-my-amqprabbitmq-talk/
 
  ZeroMQ's analysis of the messaging technology market
    http://www.zeromq.org/whitepapers:market-analysis
 
  Pieter Hintjens's background to AMQP
    http://www.openamq.org/doc:amqp-background
 
  Barry Pederson's py-amqplib
    http://barryp.org/software/py-amqplib/
 
  Ben Hood on writing an AMQP client
    http://hopper.squarespace.com/blog/2008/6/21/build-your-own-amqp-client.html
 
  Dmitriy Samovskiy introduces Ruby + QPid + RabbitMQ
    http://somic-org.homelinux.org/blog/2008/06/24/ruby-amqp-rabbitmq-example/
 
  Ben Hood's as3-amqp
    http://github.com/0x6e6562/as3-amqp
    http://hopper.squarespace.com/blog/2008/7/4/server-side-as3.html
    http://hopper.squarespace.com/blog/2008/3/24/as3-amqp-client-first-cut.html
 
  RabbitMQ's protocol code generator
    http://hg.rabbitmq.com/rabbitmq-codegen/
 
  Erlang Exchange presentation on the implementation of RabbitMQ
    http://skillsmatter.com/podcast/erlang/presenting-rabbitmq-an-erlang-based-implementatio-nof-amqp
    http://www.lshift.net/blog/2008/07/01/slides-from-our-erlang-exchange-talk
 
  Jonathan Conway's series on RabbitMQ and using it with Ruby/Merb
    http://jaikoo.com/2008/3/20/daemonize-rabbitmq
    http://jaikoo.com/2008/3/14/oh-hai-rabbitmq
    http://jaikoo.com/2008/2/29/friday-round-up-2008-02-29
    http://jaikoo.com/2007/9/4/didn-t-you-get-the-memo
 
  Open Enterprise's series on messaging middleware and AMQP
    http://www1.interopsystems.com/analysis/can-amqp-break-ibms-mom-monopoly-part-1.html
    http://www1.interopsystems.com/analysis/can-amqp-break-ibms-mom-monopoly-part-2.html
    http://www1.interopsystems.com/analysis/can-amqp-break-ibms-mom-monopoly-part-3.html
 
Messaging and distributed systems resources:
 
  A Critique of the Remote Procedure Call Paradigm
    http://www.cs.vu.nl/~ast/publications/euteco-1988.pdf
 
  A Note on Distributed Computing
    http://research.sun.com/techrep/1994/smli_tr-94-29.pdf
 
  Convenience Over Correctness
    http://steve.vinoski.net/pdf/IEEE-Convenience_Over_Correctness.pdf
 
  Metaprotocol Taxonomy and Communications Patterns
    http://hessian.caucho.com/doc/metaprotocol-taxonomy.xtp
 
  Joe Armstrong on Erlang messaging vs RPC
    http://armstrongonsoftware.blogspot.com/2008/05/road-we-didnt-go-down.html
 
  SEDA: scalable internet services using message queues
    http://www.eecs.harvard.edu/~mdw/papers/seda-sosp01.pdf