Skip to content

Commit

Permalink
Converting more tests.
Browse files Browse the repository at this point in the history
  • Loading branch information
treeder committed Apr 22, 2014
1 parent da64511 commit 8ffc655
Show file tree
Hide file tree
Showing 5 changed files with 413 additions and 404 deletions.
20 changes: 10 additions & 10 deletions README.md
Expand Up @@ -77,10 +77,10 @@ queue.id # => "5127bf043264140e863e2283"

--

### Get a Message off a Queue
### Reserve/Get a Message from a Queue

```ruby
msg = queue.get
msg = queue.reserve
msg.body # => "hello world!"
```

Expand Down Expand Up @@ -220,13 +220,13 @@ Default is 604,800 seconds (7 days). Maximum is 2,592,000 seconds (30 days).
### Get Messages from a Queue

```ruby
message = queue.get # => #<IronMQ::Message:...>
message = queue.reserve # => #<IronMQ::Message:...>

# or N messages
messages = queue.get(:n => 7) # => [#<IronMQ::Message:...>, ...]
messages = queue.reserve(:n => 7) # => [#<IronMQ::Message:...>, ...]

# or message by ID
message = queue.get "5127bf043264140e863e2283" # => #<IronMQ::Message:...>
message = queue.get_message "5127bf043264140e863e2283" # => #<IronMQ::Message:...>
```

**Optional parameters:**
Expand All @@ -248,7 +248,7 @@ Otherwise, `Message` object would be returned.
Touching a reserved message extends its timeout by the duration specified when the message was created, which is 60 seconds by default.

```ruby
message = queue.get # => #<IronMQ::Message:...>
message = queue.reserve # => #<IronMQ::Message:...>

message.touch # => #<IronMQ::ResponseBase:...>
```
Expand All @@ -258,7 +258,7 @@ message.touch # => #<IronMQ::ResponseBase:...>
### Release Message

```ruby
message = queue.get # => #<IronMQ::Message:...>
message = queue.reserve # => #<IronMQ::Message:...>

response = message.release # => #<IronMQ::ResponseBase:...>
# or
Expand All @@ -275,7 +275,7 @@ Default is 0 seconds. Maximum is 604,800 seconds (7 days).
### Delete a Message from a Queue

```ruby
message = queue.get # => #<IronMQ::Queue:...>
message = queue.reserve # => #<IronMQ::Queue:...>

message.delete # => #<IronMQ::ResponseBase:...>
```
Expand Down Expand Up @@ -430,7 +430,7 @@ This creates fake `Message` objects. They contain only IDs.
After pushing a message:

```ruby
subscribers = queue.get(msg.id).subscribers # => [#<IronMQ::Subscriber:...>, ...]
subscribers = queue.get_message(msg.id).subscribers # => [#<IronMQ::Subscriber:...>, ...]

subscribers.each { |ss| puts "#{ss.id}: #{(ss.code == 200) ? 'Success' : 'Fail'}" }
```
Expand All @@ -445,7 +445,7 @@ This creates fake `IronMQ::Message` instance on which you call for subscribers'
### Acknowledge / Delete Message Push Status

```ruby
subscribers = queue.get(msg.id).subscribers # => [#<IronMQ::Subscriber:...>, ...]
subscribers = queue.get_message(msg.id).subscribers # => [#<IronMQ::Subscriber:...>, ...]

subscribers.each do |ss|
ss.delete
Expand Down
2 changes: 1 addition & 1 deletion lib/iron_mq/client.rb
Expand Up @@ -40,7 +40,7 @@ def queues_list(options = {})
is_raw = [options.delete(:raw),
options.delete('raw')].compact.first
response = parse_response(get('', options)) # GET base_url
p response
# p response
# returns list of evaluated queues
if is_raw
response.map{ |q_info| ResponseBase.new(q_info) }
Expand Down
2 changes: 1 addition & 1 deletion lib/iron_mq/queues.rb
Expand Up @@ -214,7 +214,7 @@ def get_message(id)
end

def peek_messages(options = {})
resp = call_api_and_parse_response(:get, "/messages/peek", options)
resp = call_api_and_parse_response(:get, "/messages", options)

process_messages(resp["messages"], options)
end
Expand Down

0 comments on commit 8ffc655

Please sign in to comment.