lib/activemessaging/adapters/asqs.rb
def subscribe queue_name, message_headers={}
          # look at the existing queues, create any that are missing
          queue = get_or_create_queue queue_name
          if @subscriptions.has_key? queue.name
            @subscriptions[queue.name] += 1
          else
            @subscriptions[queue.name] = 1 
          end
        end
# queue_name string, headers hash
# for sqs, make sure queue exists, if not create, then add to list of polled queues
queue_name string, headers hash
for sqs, make sure queue exists, if not create, then add to list of polled queues
queue_name string headers hash for sqs make sure queue exists if not create then add to list of polled queues
def subscribe queue_name, message_headers={}
          queue = get_or_create_queue queue_name
          if @subscriptions.has_key? queue.name
            @subscriptions[queue.name] += 1
          else
            @subscriptions[queue.name] = 1 
          end
        end
def subscribe queue_name , message_headers = { } queue = get_or_create_queue queue_name if @subscriptions . has_key? queue . name @subscriptions [ queue . name ] += 1 else @subscriptions [ queue . name ] = 1 end end
queue_name string, headers hash
for sqs, make sure queue exists, if not create, then add to list of polled queues
queue_name string headers hash for sqs make sure queue exists if not create then add to list of polled queues
# look at the existing queues, create any that are missing
queue_name
message_headers