require 'tiny_tds'

client = TinyTds::Client.new( username: 'sa',
                              password: 'secret',
                              host: '127.0.0.1',
                              port: 1433,
                              timeout: 0,
                              database: 'ServiceBrokerTest')
loop do
  results = client.execute("WAITFOR (RECEIVE * FROM NotificationsQueue);")

  results.each do |row|
    puts row['message_body']
  end
end