vendor/bundle/ruby/1.8/gems/activemessaging-0.9.0/lib/activemessaging/adapters/wmq.rb
def subscribe(q_name, headers={}, subId=NIL)
          if @queues[q_name].nil?
            get_options = headers[:get_options] || {}
            q = Queue.new(q_name, get_options)
            @queues[q_name] = q
            @queue_names << q.name
          end

          q.add_subscription
        end
# Subscribe method needed by a13g
# headers may contains a hash to give more control over the get operation on the queue
#   :get_options => {...} to specify the get options when receiving messages
#   Warning : get options are set only on the first queue subscription and are common to all the queue's subscriptions
#             Any other get options passed with subsequent subscribe on an existing queue will be discarded
# subId is never used
Subscribe method needed by a13g
headers may contains a hash to give more control over the get operation on the queue
:get_options => {...} to specify the get options when receiving messages
Warning : get options are set only on the first queue subscription and are common to all the queue's subscriptions
Any other get options passed with subsequent subscribe on an existing queue will be discarded
subId is never used
Subscribe method needed by a13g headers may contains a hash to give more control over the get operation on the queue : get_options = > { ... } to specify the get options when receiving messages Warning : get options are set only on the first queue subscription and are common to all the queue ' s subscriptions Any other get options passed with subsequent subscribe on an existing queue will be discarded subId is never used
def subscribe(q_name, headers={}, subId=NIL)
          if @queues[q_name].nil?
            get_options = headers[:get_options] || {}
            q = Queue.new(q_name, get_options)
            @queues[q_name] = q
            @queue_names << q.name
          end
          q.add_subscription
        end
def subscribe ( q_name , headers = { } , subId = NIL ) if @queues [ q_name ] . nil? get_options = headers [ :get_options ] || { } q = Queue . new ( q_name , get_options ) @queues [ q_name ] = q @queue_names << q . name end q . add_subscription end
Subscribe method needed by a13g
headers may contains a hash to give more control over the get operation on the queue
:get_options => {...} to specify the get options when receiving messages
Warning : get options are set only on the first queue subscription and are common to all the queue's subscriptions
Any other get options passed with subsequent subscribe on an existing queue will be discarded
subId is never used
Subscribe method needed by a13g headers may contains a hash to give more control over the get operation on the queue : get_options = > { ... } to specify the get options when receiving messages Warning : get options are set only on the first queue subscription and are common to all the queue ' s subscriptions Any other get options passed with subsequent subscribe on an existing queue will be discarded subId is never used
q_name
headers
subId