Module: Wal::ActiveRecordContextExtension

Included in:: ActiveRecord::ConnectionAdapters::PostgreSQLAdapter

Defined in:: lib/wal/active_record_context_extension.rb

Instance Method Summary collapse

#set_wal_watcher_context(context, prefix: "") ⇒ Object

Instance Method Details

#set_wal_watcher_context(context, prefix: "") ⇒ `Object`



5
6
7

# File 'lib/wal/active_record_context_extension.rb', line 5

def set_wal_watcher_context(context, prefix: "")
  execute "SELECT pg_logical_emit_message(true, #{quote(prefix)}, #{quote(context.to_json)})" if transaction_open?
end