Sha256: 27bc1026aa61d1560b6bc9e5a91892d8e6c1196dfdc13fc03d01f0a51c0c15e9

Contents?: true

Size: 398 Bytes

Versions: 3

Compression:

Stored size: 398 Bytes

Contents

#
# Sample : each() : Retrieve all messages from a queue
#          If no messages are on the queue, the program
#          completes without waiting
#
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

3 entries across 3 versions & 2 rubygems

Version Path
ferocia-rubywmq-2.1.1 examples/each_a.rb
rubywmq-2.1.1 examples/each_a.rb
rubywmq-2.1.0 examples/each_a.rb