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
|
The RabbitMQ JSON-RPC-channel plugin is included in the RabbitMQ
distribution. To enable it, use:
rabbitmq-plugins enable rabbitmq_jsonrpc_channel
You may wish to also use:
rabbitmq-plugins enable rabbitmq_jsonrpc_channel_examples
to serve a couple of demo webapps.
You can also compile and install it like any other plugin (see
http://www.rabbitmq.com/plugin-development.html).
To install and activate the RabbitMQ JSON-RPC channel plugin, copy all
the .ez packages *except rabbit_common* from the plugin's 'dist'
directory into the RabbitMQ server's plugin directory, use the command
at the top to enable rabbitmq_jsonrpc_channel, and restart rabbit.
Once the server starts successfully, you should be able to point your
web browser at
http://localhost:55670/rpc/rabbitmq
and get an error along the lines of
{"version":"1.1","id":null,"error":{"name":"JSONRPCError","code":404,"message":"Procedure not found","error":["http://localhost:55670/rpc/rabbitmq",""]}}
which confirms that the RabbitMQ JSON-RPC channel is ready to accept
requests.
The plugin ships with some examples. To try these, ensure no existing
RabbitMQ broker is running and then type 'make run' in the
rabbitmq-jsonrpc-channel directory. This will start a RabbitMQ broker
with the examples configured. You should be able to point your web
browser at
http://localhost:55670/
and get a webpage. Clicking on "Simple JSONRPC test" will run a small
test application. Successful output of http://localhost:55670/test/index.html
at the time of writing is:
test_main
{"installGenericProxy":{"name":"open","idempotent":false,"params":[{"name":"username","type":"str"},{"name":"password","type":"str"},{"name":"sessionTimeout","type":"num"},{"name":"virtualHost","type":"str"}]}}
open
{"installGenericProxy":{"name":"poll","idempotent":false,"params":[]}}
{"installGenericProxy":{"name":"close","idempotent":false,"params":[]}}
{"installGenericProxy":{"name":"call","idempotent":false,"params":[{"name":"method","type":"str"},{"name":"args","type":"arr"}]}}
{"installGenericProxy":{"name":"cast","idempotent":false,"params":[{"name":"method","type":"str"},{"name":"args","type":"arr"},{"name":"content","type":"str"},{"name":"props","type":"arr"}]}}
handle_channel_ready
{"q1":"test-queue-1a"}
{"q2":"test-queue-1b"}
{"consumeOk":"aa-cons-tag1"}
{"delivery":{"content":"hello, world","delivery_tag":1,"redelivered":false,"exchange":"","routing_key":"test-queue-1a","props":{"content_type":null,"content_encoding":null,"headers":null,"delivery_mode":null,"priority":null,"correlation_id":null,"reply_to":null,"expiration":null,"message_id":null,"timestamp":null,"type":null,"user_id":null,"app_id":null,"cluster_id":null}}}
{"cancelOk":"aa-cons-tag1"}
{"delivery2":{"content":"hello, world, again! pub 2","delivery_tag":2,"redelivered":false,"exchange":"","routing_key":"test-queue-1b","props":{"content_type":null,"content_encoding":null,"headers":null,"delivery_mode":null,"priority":null,"correlation_id":null,"reply_to":"something22","expiration":null,"message_id":null,"timestamp":null,"type":null,"user_id":null,"app_id":null,"cluster_id":null}}}
{"installGenericProxy":{"name":"poll","idempotent":false,"params":[]}}
{"installGenericProxy":{"name":"close","idempotent":false,"params":[]}}
{"installGenericProxy":{"name":"call","idempotent":false,"params":[{"name":"method","type":"str"},{"name":"args","type":"arr"}]}}
{"installGenericProxy":{"name":"cast","idempotent":false,"params":[{"name":"method","type":"str"},{"name":"args","type":"arr"},{"name":"content","type":"str"},{"name":"props","type":"arr"}]}}
test basic.cancel compliance
queue declare OK
{"delivery4":{"content":"One","delivery_tag":1,"redelivered":false,"exchange":"","routing_key":"test-queue-4","props":{"content_type":null,"content_encoding":null,"headers":null,"delivery_mode":null,"priority":null,"correlation_id":null,"reply_to":null,"expiration":null,"message_id":null,"timestamp":null,"type":null,"user_id":null,"app_id":null,"cluster_id":null}}}
{"never existed":"this-never-existed"}
{"cancelled":"my-consumer"}
The source to the test program is in
priv/www-examples/test/test.js and
priv/www-examples/test/index.html
For any questions, comments and suggestions regarding the RabbitMQ
JSON-RPC channel plugin, please post to the RabbitMQ mailing list at
http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
|
