# File lib/rubyrep/replication_extenders/postgresql_replication.rb, line 103 def create_replication_trigger(params) create_or_replace_replication_trigger_function params execute("CREATE TRIGGER \"\#{params[:trigger_name]}\"\nAFTER INSERT OR UPDATE OR DELETE ON \"\#{params[:table]}\"\nFOR EACH ROW EXECUTE PROCEDURE \#{schema_prefix}\"\#{params[:trigger_name]}\"();\n") end