Amqparty
A AMQP-HTTP compliant modification of HTTParty for use with jackalope
Installation
Add this line to your application's Gemfile:
gem 'amqparty'
And then execute:
$ bundle
Or install it yourself as:
$ gem install amqparty
Usage
First configure AMQParty to connect to your AMQP broker (RabbitMQ or other)
AMQParty.configure do |c|
c.amqp_host = 'localhost'
endThen you can use it to talk to your service:
AMQParty.get("amqp://queue.name/path")Uri scheme must be amqp or amqps. Hostname is actually the queue name.
Post and put also work. Delete, head, options are untested.
Valid configuration parameters are shown below:
| Parameters | Description | Default Value |
|---|---|---|
| amqp_host | host name or IP address of the rabbitmq server | localhost |
| port | rabbitmq server port | 5672 |
| username | username to use for the rabbitmq server connection | guest |
| password | password to use for the rabbitmq server connection | guest |
| tls | use TLS when connecting to the rabbitmq server | false |
| tls_ca_certificates | an array of paths to CA certificates in pem format | [] |
| tls_cert | path to the client certificate for SSL connections in pem format | nil |
| tls_key | path to the client private key for SSL connections in pem format | nil |
| verify_peer | disable/enable peer verification (used with TLS) | false |
| request_timeout | value in seconds indicating the reply wait timeout for an amqp request | 5 |
| hearbeat | value in seconds indicating the heartbeat | 60 |
Contributing
- Fork it
- Create your feature branch (
git checkout -b my-new-feature) - Commit your changes (
git commit -am 'Add some feature') - Push to the branch (
git push origin my-new-feature) - Create new Pull Request