class ActiveMessaging::Adapters::Sqs::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/sqs.rb, line 423 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/sqs.rb, line 428 def add @count += 1 end
remove()
click to toggle source
# File lib/activemessaging/adapters/sqs.rb, line 432 def remove @count -= 1 end