Sha256: 03d30794e414e30d30e6df28d3c560ab258f013039410a4134536047f4dd2320

Contents?: true

Size: 420 Bytes

Versions: 11

Compression:

Stored size: 420 Bytes

Contents

#
# Sample : each() : Retrieve all messages from a queue
#          If no messages are on the queue, the program
#          completes without waiting
#
require 'rubygems'
require 'wmq'

WMQ::QueueManager.connect(:q_mgr_name=>'REID') do |qmgr|
  qmgr.open_queue(:q_name=>'TEST.QUEUE', :mode=>:input) do |queue|
    queue.each do |message|
      puts "Data Received: #{message.data}"
    end
  end
  puts 'Completed.'
end

Version data entries

11 entries across 11 versions & 3 rubygems

Version Path
ferocia-rubywmq-2.0.7 examples/each_a.rb
ferocia-rubywmq-2.0.6 examples/each_a.rb
ferocia-rubywmq-2.0.4 examples/each_a.rb
ferocia-rubywmq-2.0.3 examples/each_a.rb
ferocia-rubywmq-2.0.2 examples/each_a.rb
ekaranto-rubywmq-2.0.2 examples/each_a.rb
rubywmq-2.0.2 examples/each_a.rb
rubywmq-2.0.1 examples/each_a.rb
ekaranto-rubywmq-2.0.0 examples/each_a.rb
rubywmq-2.0.0 examples/each_a.rb
rubywmq-2.0.0.pre3 examples/each_a.rb