# 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