# File lib/rubyrep/replication_initializer.rb, line 31 def create_trigger(database, table) options = self.options(table) params = { :trigger_name => "#{options[:rep_prefix]}_#{table}", :table => table, :keys => session.send(database).primary_key_names(table), :log_table => "#{options[:rep_prefix]}_pending_changes", :activity_table => "#{options[:rep_prefix]}_running_flags", :key_sep => options[:key_sep], :exclude_rr_activity => false, } session.send(database).create_replication_trigger params end