class ActiveMessaging::Adapters::AmazonSqs::Subscription

Attributes

count[RW]
destination[RW]
headers[RW]
priority[RW]

Public Class Methods

new(destination, headers={}, count=1) click to toggle source
# 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

Public Instance Methods

add() click to toggle source
# File lib/activemessaging/adapters/asqs.rb, line 435
def add
  @count += 1
end
remove() click to toggle source
# File lib/activemessaging/adapters/asqs.rb, line 439
def remove
  @count -= 1
end