README.md

PG Notify Example

$ createdb pg_notify

$ ruby publisher.rb

$ ruby subscriber.rb

publisher.rb

require "sequel"
require "pg"

DB = Sequel.connect("postgres://localhost/pg_notify")

puts "payload to publish:"
loop do
  payload = STDIN.gets
  DB.notify(:event_log_head, payload: payload)
end

subscriber.rb

require "sequel"
require "pg"

DB = Sequel.connect("postgres://localhost/pg_notify")

DB.listen(:event_log_head, loop: true) do |_channel, _pid, payload|
  puts payload
end