1
0
Fork 0
burlesque-ruby/README.md

98 lines
1.9 KiB
Markdown
Raw Permalink Normal View History

2014-08-16 09:55:46 +00:00
# Burlesque message queue client
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
Ruby wrapper over [Burlesque message queue](https://github.com/KosyanMedia/burlesque) API
2014-08-15 12:29:07 +00:00
## Installation
2014-08-16 09:55:46 +00:00
```
gem install burlesque-client
```
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
## Configuration
Client defaults are the same as Burlesque server defaults.
If you're using non-standard settings, you can configure client to use them instead.
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
```ruby
Burlesque.configure do |c|
c.host = '10.10.5.155'
c.port = 4402
c.timeout = 30
end
```
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
## Usage
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
### Publish
2014-08-16 09:58:23 +00:00
```ruby
2014-08-16 09:55:46 +00:00
require 'burlesque'
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
client = Burlesque::Client.new
queue = 'urgent'
msg = 'Process this message as soon as possible!'
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
if client.publish(queue, msg)
puts 'Message successfully published!'
else
puts 'Failed to publish message'
end
```
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
### Subscribe
2014-08-16 09:58:23 +00:00
```ruby
2014-08-16 09:55:46 +00:00
require 'burlesque'
client = Burlesque::Client.new
res = client.subscribe('urgent', 'someday', 'never')
if res.nil?
puts 'No messages'
else
puts "Message from queue #{res[:queue]}:"
puts res[:message]
end
```
### Status
2014-08-16 09:58:23 +00:00
```ruby
2014-08-16 09:55:46 +00:00
require 'json'
require 'burlesque'
client = Burlesque::Client.new
puts JSON.pretty_generate(client.status)
```
### Debug
2014-08-16 09:58:23 +00:00
```ruby
2014-08-16 09:55:46 +00:00
require 'json'
require 'burlesque'
client = Burlesque::Client.new
puts JSON.pretty_generate(client.debug)
```
## CLI
```
$ bsq --help
Usage:
Publish:
$ bsq pub urgent "Process this message as soon as possible!"
or
$ cat urgent-183.txt | bsq pub urgent
Subscribe:
$ bsq sub urgent > urgent-184.txt
Status:
$ bsq status
Debug:
$ bsq debug
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
Options:
-h, --host [HOST] Burlesque host
-p, --port [PORT] Burlesque port
-t, --timeout [TIMEOUT] Subscription timeout
-v, --version Display Burlesque Ruby client version
--help Display this help message
```
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
## Licence
2014-08-15 12:29:07 +00:00
2014-08-16 09:55:46 +00:00
[MIT](https://github.com/KosyanMedia/burlesque-ruby/blob/master/LICENCE.txt)