test.rb

#!/usr/bin/env ruby
require_relative "../lib/database.rb"


EM.run do
  Database.pool.wait_for_notify_defer(10).callback do |notification|
    puts "hello world notification"
  end.errback do |ex|
    puts "Errback"
  end

  puts "here"
  Database.pool.query_defer("LISTEN #{AppConfig.channel}") do
    Database.pool.query_defer("NOTIFY #{AppConfig.channel}")
    puts "notified"
  end
end