Object
# File lib/activemessaging/adapters/asqs.rb, line 430 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 435 def add @count += 1 end
# File lib/activemessaging/adapters/asqs.rb, line 439 def remove @count -= 1 end
[Validate]
Generated with the Darkfish Rdoc Generator 2.