diff options
Diffstat (limited to 'src/exchangedb/pg_insert_aml_decision.c')
| -rw-r--r-- | src/exchangedb/pg_insert_aml_decision.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/exchangedb/pg_insert_aml_decision.c b/src/exchangedb/pg_insert_aml_decision.c index 62645c2a2..39419be59 100644 --- a/src/exchangedb/pg_insert_aml_decision.c +++ b/src/exchangedb/pg_insert_aml_decision.c @@ -49,13 +49,14 @@ TEH_PG_insert_aml_decision ( .header.type = htons (TALER_DBEVENT_EXCHANGE_KYC_COMPLETED), .h_payto = *h_payto }; - char *notify_s = GNUNET_PG_get_event_notify_channel (&rep.header); + char *notify_s = GNUNET_PQ_get_event_notify_channel (&rep.header); char *kyc_s = (NULL != kyc_requirements) ? json_dumps (kyc_requirements, JSON_COMPACT) : NULL; struct GNUNET_PQ_QueryParam params[] = { GNUNET_PQ_query_param_auto_from_type (h_payto), - TALER_PQ_query_param_amount (new_threshold), + TALER_PQ_query_param_amount (pg->conn, + new_threshold), GNUNET_PQ_query_param_uint32 (&ns), GNUNET_PQ_query_param_timestamp (&decision_time), GNUNET_PQ_query_param_string (justification), @@ -83,12 +84,13 @@ TEH_PG_insert_aml_decision ( " out_invalid_officer" ",out_last_date" " FROM exchange_do_insert_aml_decision" - "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11);"); + "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10);"); qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn, "do_insert_aml_decision", params, rs); GNUNET_free (notify_s); + GNUNET_PQ_event_do_poll (pg->conn); if (NULL != kyc_s) free (kyc_s); return qs; |