command
module
Version:
v0.0.0-...-147e282
Opens a new window with list of versions in this module.
Published: Sep 22, 2013
License: BSD-3-Clause
Opens a new window with license information.
Imports: 7
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
README
¶
RabbitMQ HTTP API
REST HTTP API for RabbitMQ, it's not RabbitMQ Management Plugin.
Status:
Under active development.
Required:
* RabbitMQ (2.8+)
* Go(lang) (1.0.3)
Install:
$ go get github.com/streadway/amqp
$ go get github.com/smallfish/rabbitmq-http
Usage
HTTP Response
200 OK
405 Method Not Allowed
500 Internal Server Error
API List
Exchange
-
create new exchange:
$ curl -i -X POST http://127.0.0.1:8080/exchange -d \
'{"name": "e1", "type": "topic", "durable": true, "autodelete": false}'
HTTP/1.1 200 OK
Date: Thu, 21 Mar 2013 05:45:47 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
declare exchange ok
-
delete exchange:
$ curl -i -X DELETE http://127.0.0.1:8080/exchange -d \
'{"name": "e1"}'
HTTP/1.1 200 OK
Date: Thu, 21 Mar 2013 05:46:21 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
delete exchange ok
Message
-
publish new message:
$ curl -i -X POST "http://127.0.0.1:8080/publish" -d \
'{"exchange": "e1", "key": "bb", "deliverymode": 1, "priority": 99, "body": "hahaha"}'
HTTP/1.1 200 OK
Date: Mon, 25 Mar 2013 11:56:22 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
publish message ok
Queue
-
create new queue:
$ curl -i -X POST http://127.0.0.1:8080/queue -d \
'{"name": "q1"}'
HTTP/1.1 200 OK
Date: Thu, 21 Mar 2013 05:47:11 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
declare queue ok
-
delete queue:
$ curl -i -X DELETE http://127.0.0.1:8080/queue -d \
'{"name": "q1"}'
HTTP/1.1 200 OK
Date: Thu, 21 Mar 2013 05:48:05 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
delete queue ok
-
bind keys to queue:
$ curl -i -X POST http://127.0.0.1:8080/queue/bind -d \
'{"queue": "q1", "exchange": "e1", "keys": ["aa", "bb", "cc"]}'
HTTP/1.1 200 OK
Date: Thu, 21 Mar 2013 05:48:43 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
bind queue ok
-
unbind keys to queue:
$ curl -i -X DELETE http://127.0.0.1:8080/queue/bind -d \
'{"queue": "q1", "exchange": "e1", "keys": ["aa", "cc"]}'
HTTP/1.1 200 OK
Date: Thu, 21 Mar 2013 05:49:05 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
unbind queue ok
-
consume queue:
$ curl -i -X GET "http://127.0.0.1:8080/queue?name=q1" # more queues: "/queue?name=q1&name&q2"
HTTP/1.1 200 OK
Date: Fri, 22 Mar 2013 04:11:59 GMT
Transfer-Encoding: chunked
Content-Type: text/plain; charset=utf-8
<DATA>\n
<DATA>\n
...
Copyright and License
rabbitmq-http is licensed under the BSD license.
Documentation
¶
There is no documentation for this package.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.