Object
# File lib/activemessaging/adapters/asqs.rb, line 424 def initialize(destination, headers={}, count=1) @priority = headers.delete(:priority) || 1001 @destination, @headers, @count = destination, headers, count end
# File lib/activemessaging/adapters/asqs.rb, line 429 def add @count += 1 end
# File lib/activemessaging/adapters/asqs.rb, line 433 def remove @count -= 1 end
[Validate]
Generated with the Darkfish Rdoc Generator 2.